akka - 带有临时队列的 Alpakka JMS 请求/响应 - 开箱即用？

Question

考虑将一些基于 JMS 的遗留系统迁移到 Alpakka，代码中广泛使用的模式之一是使用临时队列 (JMSReplyTo) 的请求/响应。开箱即用的 Alpakka 是否可行？

Answer 1

是的，Alpakka 的 JMS 模块确实支持JMSReplyTo. 文档中的一个示例：

val msgsIn = (1 to 10).toList.map { n =>
  JmsTextMessage(n.toString)
    .withHeader(JmsType("type"))
    .withHeader(JmsCorrelationId("correlationId"))
    .withHeader(JmsReplyTo.queue("test-reply")) // <---
    .withHeader(JmsTimeToLive(FiniteDuration(999, TimeUnit.SECONDS)))
    .withHeader(JmsPriority(2))
    .withHeader(JmsDeliveryMode(DeliveryMode.NON_PERSISTENT))
}