How do I use custom headers for exchanges and when sending messages? #36
Description
I am trying to use a plugin: https://github.com/rabbitmq/rabbitmq-delayed-message-exchange, to handle delayed message scheduling. This plugin needs custom headers on the message, as well as on the exchange when it is created.
exchange:
- type set to
x-delayed-message - arguments:
{'x-delayed-type: 'direct'},
message:
{'x-delay': 5000}
I am using send/receive pattern with rabbus, what is the best way to set these values?