search

jxsl13 / amqpx

A robust amqp wrapper library for RabbitMQ's amqp091-go. Connection pooling, reconnect handling, batch processing and more.
MIT License
13 stars 1 forks source link

dead letter queues #25

Open john-behm-bertelsmann opened 1 year ago

john-behm-bertelsmann commented 1 year ago

Configured by the same key value pairs that configure the quorum queue attribute.

x-dead-letter-exchange

Optional name of an exchange to which messages will be republished if they are rejected or expire.

x-dead-letter-routing-key Optional replacement routing key to use when a message is dead-lettered. If this is not set, the message's original routing key will be used.

jxsl13 commented 6 months ago

TODO: create a convenience function for creating a deadletter config amqp091-go.Table map and maybe another function that can extend an existing config map.