jms - 使用 JMS 连接器 Alpakka 的持久订户

Question

使用 Alpakka，我们可以使用以下代码为任何主题创建非持久订阅者：

Source<String, NotUsed> jmsTopicSource = JmsSource
    .textSource(JmsSourceSettings
        .create(connectionFactory)
        .withTopic("topic")
        .withBufferSize(10)
    );

有谁知道如何使这个主题订阅者持久？

Answer 1

我认为 Alpakka 的 JMS 连接器不支持创建持久消费者，从 0.9 版开始。在内部 API 中，JmsConnector正在调用Session#createConsumer：

private[jms] def createConsumer()(implicit ec: ExecutionContext): Future[jms.MessageConsumer] =
  Future {
    session.createConsumer(destination)
  }

似乎没有一种方法可以调用Session#createDurableConsumerJMSSession对象提供的任何方法（例如 ）来创建持久消费者。