2017-11-25 4 views

答えて

1

はい、サポートされていますが、追加のプラグインを介してのみサポートされています。

There is more dateiled about that

は、単にあなたがrabbitmq-plugins enable rabbitmq_delayed_message_exchangeプラグインをインストールして、あなたのメッセージに新しいヘッダを追加する必要があると言って:

byte[] messageBodyBytes = "delayed payload".getBytes(); 
AMQP.BasicProperties.Builder props = new AMQP.BasicProperties.Builder(); 
headers = new HashMap<String, Object>(); 
headers.put("x-delay", 5000); 
props.headers(headers); 
channel.basicPublish("my-exchange", "", props.build(), messageBodyBytes); 

ですから、このメッセージが処理されるべき後にミリ秒単位でx-delay値を配置する必要があります。

+0

Pythonで別の代替メカニズムをお勧めしますか?ユーザーが後で実行するためにイベント(日付)をキューに入れることができるとき? – Oleg

+0

ストレージから日付を取得し、これをCountdown EATに送るにはどうすればいいですか?何も停止しないたびに私はpingデータベースが必要ですか? – Oleg

+0

この方法では、datetime形式の遅延時間をサポートしていません。ちょうどミリ秒です – Oleg

関連する問題