[BEAM-2246] JmsIO should use CLIENT_ACK instead of AUTO_ACK

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 0.6.0
• Fix Version/s: 2.1.0
• Component/s: io-java-jms
• Assignee: Jean-Baptiste Onofré
• Reporter: Jean-Baptiste Onofré
• Created: 10/May/17 08:49
• Updated: 16/May/20 13:31
• Resolved: 31/May/17 19:29

Description

As JmsIO manages the messages acknowledgement in its checkpoint, it should not use AUTO_ACKNOWLEDGE but CLIENT_ACKNOWLEDGE.

With AUTO_ACK, the ack is sent to the JMS broker as soon as the message is consumed. Basically, it means that the checkpoint is useless as, if something goes wrong in the pipeline, the messages is already consumed from the broker (so no way to redeliver the message).

Instead, JmsIO should use CLIENT_ACK and explicitly send the ack (commit) in the checkpoint (the code is already in place).

Issue Links

• links to: GitHub Pull Request #3073