java - 如何在 Alpakka 中使用 Source.queue

Question

我正在尝试为可以多次使用的 JMS 队列创建一个生产者；即，我不想在每次发送消息时都创建与队列的连接。我想要一个打开连接的演员，每次收到消息时，它都使用相同的流程。

演员初始化

 Sink<String, CompletionStage<Done>> jmsSink = JmsProducer
        .textSink(
            JmsProducerSettings
                .create(connectionProvider.get())
                .withQueue(queueName)
        );

 someActor = Source
        .queue(Integer.MAX_VALUE, OverflowStrategy.backpressure())
        .runWith(jmsSink, materializer); // it doesn't like jmsSink, it wants a graph

演员 onMessage

 someActor.tell(foo); // something like this