diff options
Diffstat (limited to 'qpid/java/client/src/main/java/org/apache/qpid/client/XASessionImpl.java')
-rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/XASessionImpl.java | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/XASessionImpl.java b/qpid/java/client/src/main/java/org/apache/qpid/client/XASessionImpl.java index 85623df8c0..6d5bf9ad67 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/XASessionImpl.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/XASessionImpl.java @@ -18,6 +18,7 @@ package org.apache.qpid.client; import org.apache.qpid.client.message.MessageFactoryRegistry; +import org.apache.qpid.transport.RangeSet; import javax.jms.JMSException; import javax.jms.QueueSession; @@ -178,4 +179,17 @@ public class XASessionImpl extends AMQSession_0_10 implements XASession, XATopic { return (TopicSession) getSession(); } + + @Override + protected void acknowledgeImpl() + { + if (_xaResource.isEnlisted()) + { + acknowledgeMessage(Long.MAX_VALUE, true) ; + } + else + { + super.acknowledgeImpl() ; + } + } } |