How do I use custom headers for exchanges and when sending messages?

[jnystrom]

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?