我是否需要多次创建ActorMaterializer？

Question

我有一个使用akka-http + akka-actors + akka-camel + akka-streams生成报告的应用程序。当发布请求到达时，ActiveMqProducerActor将请求排队到ActiveMq Broker中。然后ActiveMqConsumerActor使用消息并使用akka-streams启动任务（在这个actor中，我需要实现器）。主类创建ActorSystem和ActorMaterializer，但是我不知道将物化器“注入” akka-actor的正确方法是什么

object ReportGeneratorApplication extends App {

  implicit val system: ActorSystem = ActorSystem()
  implicit val executor = system.dispatcher
  implicit val materializer = ActorMaterializer()

 val camelExtension: Camel = CamelExtension(system);
 val amqc: ActiveMQComponent = ActiveMQComponent.activeMQComponent(env.getString("jms.url"))
 amqc.setUsePooledConnection(true)
 amqc.setAsyncConsumer(true)
 amqc.setTrustAllPackages(true)
 amqc.setConcurrentConsumers(1)
 camelExtension.context.addComponent("jms", amqc);
 val jmsProducer: ActorRef = system.actorOf(Props[ActiveMQProducerActor])

 //Is this the correct way to pass the materializer?
 val jmsConsumer: ActorRef = system.actorOf(Props(new ActiveMQConsumerActor()(materializer)), name = "jmsConsumer")

 val endpoint: ReportEndpoint = new ReportEndpoint(jmsProducer);
 Http().bindAndHandle(endpoint.routes, "localhost", 8881)
}

具有jmsProducerActor的ReportEndPoint类。Mongo是CRUD方法的一个特征。JsonSupport（== SprayJsonSupport）

class ReportEndpoint(jmsProducer: ActorRef)
                 (implicit val system:ActorSystem,
                                        implicit val executor: ExecutionContext,
                                        implicit val materializer : ActorMaterializer)
  extends JsonSupport with Mongo {


  val routes =  
              pathPrefix("reports"){
                post {
                  path("generate"){
                    entity(as[DataRequest]) { request =>
                      val id = java.util.UUID.randomUUID.toString

                      // **Enqueue the request into ActiveMq** 
                      jmsProducer ! request
                      val future: Future[Seq[Completed]]  = insertReport(request)
                      complete {
                        future.map[ToResponseMarshallable](r => r.head match {
                          case r : Completed => println(r); s"Reporte Generado con id $id"
                          case _ => HttpResponse(StatusCodes.InternalServerError, entity = "Error al generar reporte")
                        })
                      }
                    }
                  }
                } ....

ActiveMqConsumerActor的想法是通过流和反压一一发送消息，因为ReportBuilderActor进行了许多mongo操作（以及它的数据中心不是很好）。

//Is this the correct way to pass the materializer??
class ActiveMQConsumerActor (implicit materializer : ActorMaterializer) extends Consumer with Base {
  override def endpointUri: String = env.getString("jms.queue")
  val log = Logging(context.system, this)
  val reportActor: ActorRef = context.actorOf(Props(new  ReportBuilderActor()(materializer)), name = "reportActor")

  override def receive: Receive = {
    case msg: CamelMessage => msg.body match {
        case data: DataRequest => {
    //I need only one task running
    Source.single(data).buffer(1, OverflowStrategy.backpressure).to(Sink.foreach(d => reportActor ! d)).run()
  }
    case _ => log.info("Invalid")
    }
    case _ => UnhandledMessage
  }
}

一个好主意在伴随对象中具有隐式值吗？谢谢！！