jms - camelを使用してactivemqキューからメッセージを読み取るためのタイムアウトを指定する

Question

キャメルを使用して、activemq キューからメッセージを読み取り、処理して別のキューに投稿しています。ルートは次のようになります。

from("jms:incoming.queue")
.process(new MyProcessor())
.to("jms:outgoing.queue");

「incoming.queue」に 3 分以上メッセージがない場合にルートを停止するように、タイムアウトを指定する必要があります。OnCompletion() を使用できますが、各メッセージの後に呼び出されます。「outgoing.queue」へのメッセージ送信のタイムアウトを指定できます。「incoming.queue」に 3 分以上メッセージがない場合にルートを停止できるように、タイムアウトを指定する方法はありますか?

よろしくお願いします。

Answer 1

上記のコメントに基づくと、スケジュールどおりにルートを開始および停止しようとしているようです。クォーツジョブを使用して、jmsルートのstartメソッドとstopメソッドを呼び出すことができます。必要に応じて、クォーツエンドポイントを使用してクォーツロジックをルートにすることもできます。