RabbitMQ: How to requeue message with counter

go rabbitmq amqp
fzerorubigd picture fzerorubigd · Aug 10, 2014 · Viewed 17.6k times · Source

Is there any way to count how many time a job is requeued (via Reject or Nak) without manually requeu the job? I need to retry a job for 'n' time and then drop it after 'n' time.

ps : Currently I requeue a job manually (drop old job, create a new job with the exact content and an extra Counter header if the Counter is not there or the value is less than 'n')

Answer

pinepain picture pinepain · Aug 11, 2014

There are redelivered message property that set to true when message redelivered one or more time.

If you want to track redelivery count or left redelivers number (aka hop limit or ttl in IP stack) you have to store that value in message body or headers (literally - consume message, modify it and then publish it modified back to broker).

There are also similar question with answer which may help you: How do I set a number of retry attempts in RabbitMQ?

Related questions

Unmarshaling Into an Interface{} and Then Performing Type Assertion

I get a string through a rabbitmq message system. Before sending, I use json.Marshal, convert the outcome to string and send through rabbitmq. The structs that I convert and send can be: (changed the names and the size of …

Read More
How to check if a map contains a key in Go?

I know I can iterate over a map m by, for k, v := range m { ... } and look for a key but is there a more efficient way of testing a key's existence in a map? I couldn't find the answer …

Read More
How can I convert a zero-terminated byte array to string?

I need to read [100]byte to transfer a bunch of string data. Because not all of the strings are precisely 100 characters long, the remaining part of the byte array is padded with 0s. If I convert [100]byte to string by: …

Read More