2016-05-27 1 views

答えて

0

消費者が24時間遅れてメッセージを消費するのではなく、メッセージをキューに入れてから24時間遅れて受信することをお勧めします。

は、我々は、この設定を使用した後、ActiveMQのは、24時間の遅延によって配信されるメッセージのスケジュールを設定します

long time = 24 hours in milliseconds; 
message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, time); 
producer.send(message) 

を使用してそれを行うことができます。

PS:あなただけの小さな事を確認する必要があります、ブローカーはメッセージが配信される前にダウンし、それが正常に送信されますないときに何が起こるか、ブローカーが再び稼働して

ある場合

・ホープこのことができます!

幸運を祈る!

+0

こんにちは、私はこれを行うことはできません実際には、DLQからのメッセージを処理するために私は正常に処理されていないメッセージを受信した主なqueue.so基本的には、 DLQから24時間後にメッセージ。 – user4045063

+0

これらの例外的なシナリオについては、質問を投稿するときに言及してください – Vihar

関連する問題