rabbitmq-delayed-message-exchange
rabbitmq-delayed-message-exchange copied to clipboard
rabbitmq
Delayed Messaging for RabbitMQ
Hello, I've encountered a small problem with the delayed exchange. I have and exchange defined like this : ``` Map arguments = new HashMap(); arguments.put("alternate-exchange", "my-alternate-exchange" ) arguments.put("x-delayed-type", "fanout"); channel.exchangeDeclare("my-delayed-exchange",...
As mentioned on the link https://www.rabbitmq.com/blog/2015/04/16/scheduling-messages-with-rabbitmq/ The plugin doesn't negate the value of delay provided in the header. The POC I did still shows the same positive value. `delayed-consumer processed...
### Motivation: Since the `x-delay` is a message header attribute, delay can only be specified per message and through publisher's code. **There should be an alternative way for specifying the...
What i'm trying to do with the plugin is to nack/reject message to dead letter exchange (which has a type equal to `'x-delayed-message'`) if there was any `recoverableError` during message...
If the `rabbit_delayed_message` process is restarted, a timer is not being started automatically until `go` is called or a new message is scheduled for delay. This can cause significant delays...
Hey guys, currently we have the following setup: One global RabbitMQ instance and several vhost and we are using the delayed-message-exchange plugin. In the last days we had the problem...
Some messages delay might expire while RabbitMQ was shut down. At the moment we just deliver those messages during startup. A user asks if said messages can be DLX'ed instead...
### Is your feature request related to a problem? Please describe. The rabbitmq-delayed-message-exchange plugin does not list 3.13 as supported version yet. Version 3.13 of RabbitMQ-Server released recently. Running e.g....
## Proposed Changes NOTE THE CODE IS NOT UP FOR REVIEW AT THIS POINT. High level design: * store msg metadata in khepri * unique key * time when to...
### Describe the bug While testing a PR on my plugin: https://github.com/noxdafox/rabbitmq-message-deduplication/pull/105 I could not manage to build it anymore. I could not track the core issue but I noticed...
