Ja7ad / amqp

Wrapped amqp091-go with specific stable/safe regarding connection (Production Ready)
MIT License
7 stars 1 forks source link

implement delay concept for nack or rejected message #5

Open Ja7ad opened 9 months ago

Ja7ad commented 9 months ago

Describe the problem you'd like to have solved

Your consumer can not handle the received message and you need to reject it. If you reject the message with requeue being true, it will be instantly redelivered to your consumer, resulting in very high workload, as your consumer will reject that message.

Describe the ideal solution

flowchart

The RabbitMQ Delay Message Plugin adds a new exchange type to RabbitMQ that allows messages routed through that exchange to be delayed if the user so desires. Let us see how the deployment and scheduling go with these 2 methods.

rabbitmq-plugins enable rabbitmq_delayed_message_exchange