How to retry job that are not acknowledged ?

[s8sg]

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]

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