jms - 使用 Alpakka 对 JMS 的显式确认

Question

我目前Akka-Camel用于将基于 Akka 的应用程序与各种消息队列集成。
现在我想升级到最新版本的 Akka，我发现这个集成现在已经被弃用了。

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

Answer 1

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

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)