CODEWITHSUNDEEP
gorabbitmq
Crusaderpyro
Crusaderpyro

Reputation: 2252

RabbitMQ multiple acknowledges to same message closes the consumer

If I acknowledge the same message twice using the Delivery.Ack method, my consumer channel just closes by itself.

Is this expected behaviour? Has anyone experienced this ?

The reason I am acknowledging the same message twice is a special case where I have to break the original message into copies and process them on the consumer. Once the consumer processes everything, it loops and acks everything. Since there are copies of the entity, it acks the same message twice and my consumer channel shuts down

Upvotes: 3

Views: 1187

Answers (1)

Amir Rahimi Farahani
Amir Rahimi Farahani

Reputation: 1590

According to the AMQP reference, a channel exception is raised when a message gets acknowledged for the second time:

A message MUST not be acknowledged more than once. The receiving peer MUST validate that a non-zero delivery-tag refers to a delivered message, and raise a channel exception if this is not the case.

Second call to Ack(...) for the same message will not return an error, but the channel gets closed due to this exception received from server:

Exception (406) Reason: "PRECONDITION_FAILED - unknown delivery tag ?"

It is possible to register a listener via Channel.NotifyClose to observe this exception.

Upvotes: 4

Related Questions