For AMQP clients, increment the delivery count for the following scenario:
1. a message is delivered to application
2. session.recover() is called
3. the consumer is closed
This is relevant to non-transacted AMQP consumers; currently when a Camel client throws an exception in the following route, the re-delivery counter is not incremented and the message will continue being re-delivered forever:
from("amqp-component:mytest.queueName?cacheLevelName=CACHE_NONE&acknowledgementModeName=CLIENT_ACKNOWLEDGE")
.throwException(new Exception("FORCED EXCEPTION"));
Client Ack is a requirement here to avoid setting up a separate coordinator link for local transactions.
- is related to
-
ENTMQCL-1953 [jms] client-ack with Camel CACHE_AUTO broker-side redelivery
- Closed
- links to