2017-02-08 1 views
0

このプラグインを使用しようとしていて、とてもシンプルで効果的でした。私は交換を作成することができましたが、リクエストを公開しているときに、xディレイ値がゼロでない場合、キューにメッセージが渡されているのを見ることができません。(xディレイは0になります)rabbitmq_delayed_message_exchangeを使用している間に遅延メッセージがキューに表示されない

私はpikaとpythonを使用しています。次のコマンドは、交換を作成するために使用されました:

channel.exchange_declare(exchange="central_exchange", exchange_type='x-delayed-message', passive=False, durable=False, auto_delete=False, internal=False, arguments=args) 

メッセージを公開するために:あなたの助けのための

channel.basic_publish(
exchange="central_exchange", 
routing_key="my_queue", 
body=message, 
properties=pika.BasicProperties(headers={"x-delay": 5000}) 
) 

感謝を!

答えて

0

ログを見ると、エラーを投げていたerlangファイルを実行しようとしているプラ​​グインです。 このプラグインはErlang/OTP 18.0以降のみをサポートしているようです。 rabbitmqのスタンドアロン版がerlang 17.5にバンドルされました。 homebrew、更新されたerlangを使ってインストールしなければならなかった、今は魅力のように働いている!!

すべてのmichaelklishin(プラグインの作家)に感謝します:)

関連する問題