使用 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)
  }

似乎没有办法调用 JMS Session 对象提供的任何方法（例如，Session#createDurableConsumer）来创建持久消费者。