Запрос/ответ Alpakka JMS с временными очередями — возможен ли он из коробки?

Думая о переносе некоторого наследия на основе JMS на Alpakka, одним из широко используемых шаблонов в коде является запрос/ответ с временной очередью (JMSReplyTo). Возможно ли это с Alpakka из коробки?


jms akka alpakka
person bobah    schedule 17.04.2019    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Да, JMS-модуль Alpakka поддерживает 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))
}
person Jeffrey Chung    schedule 19.04.2019
comment
Спасибо, Джеффри, но это не временная очередь. Время жизни временных очередей связано с соединением, в котором они созданы. И соединение, используемое потоком alpakka JMS, инкапсулируется в поток. Так что я думаю, что ответ - нет. - person bobah; 22.04.2019