0
이 플러그인을 사용하려고했는데 아주 간단하고 효과적이었습니다. Exchange를 만들 수 있었지만 요청을 게시 할 때 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})
)
감사합니다!