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