Как использовать Source.queue с Alpakka

Question

Я пытаюсь создать производителя в очередь JMS, которую можно использовать более одного раза; т.е. я не хочу создавать соединение с очередью каждый раз, когда отправляю сообщение. Мне нужен актер с открытым соединением, и каждый раз, когда приходит сообщение, он использует тот же поток.

Актер init

 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

Актер на сообщение

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