Jean-Baptiste Onofré created BEAM-3920:
------------------------------------------
Summary: JmsIO should ack the message before the finalizeCheckpoint
Key: BEAM-3920
URL: https://issues.apache.org/jira/browse/BEAM-3920
Project: Beam
Issue Type: Bug
Components: io-java-jms
Reporter: Jean-Baptiste Onofré
Assignee: Jean-Baptiste Onofré
{{JmsIO}} sends back the ack to the broker in the {{finalizeCheckpoint()}}
method. However, the checkpoint doesn't seem to be fast enough (with the direct
runner at least), and the messages are still pending in the queue whereas the
data has been processed in the pipeline. This should be improved.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
