search

adjust / rmq

Message queue system written in Go and backed by Redis
MIT License
1.57k stars 206 forks source link

How to retry job that are not acknowledged ? #101

Closed s8sg closed 1 year ago

s8sg commented 3 years ago

I'm trying to handle a requirement where a consumer can get killed. And when it comes back it should retry to task it was performing.

I have 2 push queue configured and when a task fails, the delivery gets Pushed to the next queue. If successful it is Acked.

If a consumer gets killed neither the delivery.Ack() or delivery.Push() will be called. What is the way to retry the delivery that was not acknowledged ?

wellle commented 3 years ago

See https://github.com/adjust/rmq#cleaner :v: