Springがキューから受け取るレートを制御するにはどうしたらいいですか？

Question

私は、いくつかのキューやトピックを聞くために、Springのメッセージ駆動型POJOフレームワーク（特にDefaultMessageListenerContainer）を使用しています。

特に1つのキューの場合、5分ごとに1つのメッセージのオーダーで、キューを排出する速度を遅くする必要があります。メッセージの実際の処理はサブ秒の操作ですが、リスナーがメッセージの間にある程度の間アイドル状態になるようにしたいと思います。

私はちょっとしたハックを作成しましたが、明らかに準最適です。最大同時処理数を1に設定し、各メッセージの処理後にThread.sleep(..)を追加することです。私は代わりにメッセージを処理している間にハンドラが待機するようにするのではなく、受信しようとするのを待つためにDefaultMessageListenerContainerを使用する方法を見つけたいと思います。

ScheduledExecutorがあると思っていましたが、タスクが生成される場所でスロットルを行う必要があることがわかりました。 DefaultMessageListenerContainerから、後で何を達成するためにオーバーライドできる方法がありますか？

Answer 1

私は100％は分かりませんが、receiveTimeoutはあなたが望むものだと思います。

<bean id="blahContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> 
    .... 
    <!-- 300000 = 5 * 60 * 1000 == 5 min --> 
    <property name="receiveTimeout" value="300000"/> 
</bean> 

receiveTimeoutは、あなたがその1つの特定のメッセージを遅らせるためにApacheのキャメルを利用することであろうあなたの消費者の行動を修正するにjavadocs

Answer 2

代わりにそれについての詳細を読むことができ、ミリ秒単位でタイムアウトを受け入れますキュー。

http://camel.apache.org/delayer.htmlは、Camel Delayerパターンの機能を記述する。たとえば、次のようになります。

<route> 
    <from uri="jms:YOURQUEUE"/> 
    <delay> 
     <constant>1000</constant> 
    </delay> 
    <to uri="jms:DELAYEDQUEUE"/> 
</route> 

ここで、DELAYEDQUEUEを消費すると、すべてのメッセージが1秒遅れます。

Answer 3

キューのプロバイダによっては、キューを消費するコンシューマの最大レートを設定できる場合があります。

たとえば、hornetQでは、これを接続ファクトリでconsumer-max-rateを使用して設定します。