Apache Camel JmsComponent - Как проверить, есть ли сообщение в теме?

Question

У меня есть маршрут верблюда, чтобы использовать сообщение из темы JMS. Когда маршрут начинается, и в теме нет сообщения, я хочу создать исключение и остановить процесс.

Я использую JmsComponent от Apache Camel, использующего DefaultMessageListenerContainer с Spring и определяется как транзакционный. Текущее поведение заключается в том, что маршрут начинается, но он продолжает ждать сообщения бесконечно.

Есть ли решение проверить, существует ли сообщение, и просто остановить маршрут при его отсутствии?

Answer 1

Необходимо определить срок, на который вы ожидаете сообщения, и сделать вывод о том, что все пошло не так.

Затем вы используете агрегатор с таймаутом завершения (скажем) 30 секунд.

Таким образом, если вы проедете более 30 секунд без получения сообщения по этой теме, вы можете принять любое действие, которое вам нравится.

from("mq:topic:xyz") 
    .aggregate(constant(true), new TakeLastAggregationStrategy()) 
    .completionTimeout(30000) 
    .to("direct:raiseException")