CODEWITHSUNDEEP
c#node.jsrabbitmq
Jjang
Jjang

Reputation: 11444

RabbitMQ no ack usage

I'm integrating RMQ into my project, in order to implement work queues.

I understand what if module succeeded, it calls the ack method so RMQ will know about it.

What about failures?

I read that only when connection or channel are closed, RMQ knows we've failed and re-push the message to the queue.

I'd like however to make the RMQ re-push messages whenever I have an internal error, regardless of wheter I crash or not (e.g. failure to insert to DB, I handle that gracefully without crashing however I want the whole job to be re-tried).

Do I have to manually close and open the channel again in order to trigger that?

Upvotes: 1

Views: 3269

Answers (1)

cantSleepNow
cantSleepNow

Reputation: 10170

You can use negative ACK, or rejects. Info here.

The AMQP specification defines the basic.reject method that allows clients to reject individual, delivered messages, instructing the broker to either discard them or requeue them.

Upvotes: 1

Related Questions