考虑到将一些基于JMS的传统迁移到Alpakka,代码中广泛使用的模式之一是带有临时队列的请求/响应(JMSReplyTo)。Alpakka是否有可能开箱即用?
发布于 2019-04-19 20:36:57
是的,Alpakka的JMS模块确实支持JMSReplyTo。来自documentation的示例
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))
}https://stackoverflow.com/questions/55734861
复制相似问题