使用Alpakka显式确认到JMS

Question

我目前正在使用Akka-Camel来集成我的基于Akka的应用程序和各种消息队列。

现在我想升级到Akka的最新版本，我看到这个集成现在被弃用了。

我尝试过使用alpakka-jsm集成，但在处理完消息后，无法看到是否可以对消息队列执行显式ack。此新组件中是否存在此功能？

Answer 1

Alpakka JMS使0.15连接器中的确认模式可配置。下面是一个改编自链接文档的示例：

val jmsSource: Source[Message, NotUsed] = JmsSource(
  JmsSourceSettings(connectionFactory)
    .withQueue("myqueue")
    .withAcknowledgeMode(AcknowledgeMode.ClientAcknowledge)
)

val result = jmsSource
  .map {
    case textMessage: TextMessage =>
      val text = textMessage.getText
      textMessage.acknowledge()
      text
  }
  .runWith(Sink.seq)