このプラグインを使用しようとしていて、とてもシンプルで効果的でした。私は交換を作成することができましたが、リクエストを公開しているときに、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})
)
感謝を!