アクティブなmqに送信するための待ちメッセージを動的に設定する方法

Question

メッセージがアクティブなmqに送信される待機値を動的に設定する方法はありますか？
Active mqのキューに送信する前にメッセージを待つ必要があるという要件があります。私はその待機値の設定を変数から動的にできるようにする必要があります。
私はgroovyにメッセージを使用することができますが、いくつかの例を見たことがありますが、これを行うにはgroovyまたはsleep()やハックを使用したくありません。

コネクタレベルには他の方法はありますか？

Answer 1

遅れを設定するには、jmsコンポーネントにAMQ_SCHEDULED_DELAYヘッダーが必要だと思います。
フロー変数をヘッダーとして設定できます。あなたが流れラバに送信する前に、あなたが

<message-properties-transformer doc:name="Message Properties"> 
<add-message-property key="AMQ_SCHEDULED_DELAY" value="#[flowVars.delay]"/> 
</message-properties-transformer> 
<json:object-to-json-transformer doc:name="Object to JSON"/> 
<jms:outbound-endpoint queue="testqueue" connector-ref="Active_MQ" doc:name="JMS"/> 

は今、あなたはフロー変数を設定

コンポーネントレベルでの遅延時間を設定することができますどのようにここで、あなたに https://dzone.com/articles/delay-with-jms

を助けることができるあなたがここで見つけることができます
例