RabbitMQ Headers

I’m trying to create a delayed message with RabbitMQ Delayed Message Plugin. But I see that the Header parameter is missing in the RabbitMq node implementation.

Please expose the header parameter to fix this.

Usage Example

pubChannel.publish(exchange, routingKey, content, {headers: {"x-delay": delay}});

Just created a PR for this feature.

2 Likes

Ahh, thanks for the contribution. Really nice. We will be reviewing the PR as soon as we can.

Thanks a lot. Got reviewed and merged. Will be released with the next version.

1 Like

Got released with [email protected]