diff options
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/XASessionImpl.java | 15 |
1 files changed, 10 insertions, 5 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 f2efb6e8a5..05bd121bbd 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 @@ -17,6 +17,7 @@ */ package org.apache.qpid.client; +import org.apache.qpid.AMQException; import org.apache.qpid.client.message.MessageFactoryRegistry; import org.apache.qpid.transport.RangeSet; @@ -31,7 +32,7 @@ import javax.jms.XATopicSession; import javax.transaction.xa.XAResource; /** - * This is an implementation of the javax.njms.XASEssion interface. + * This is an implementation of the javax.jms.XASession interface. */ public class XASessionImpl extends AMQSession_0_10 implements XASession, XATopicSession, XAQueueSession { @@ -67,7 +68,7 @@ public class XASessionImpl extends AMQSession_0_10 implements XASession, XATopic { this(qpidConnection, con, channelId, false, ackMode, MessageFactoryRegistry.newDefaultRegistry(), defaultPrefetchHigh, defaultPrefetchLow, null); - + } public XASessionImpl(org.apache.qpid.transport.Connection qpidConnection, AMQConnection con, int channelId, @@ -92,9 +93,6 @@ public class XASessionImpl extends AMQSession_0_10 implements XASession, XATopic _qpidDtxSession.dtxSelect(); } - - // javax.njms.XASEssion API - /** * Gets the session associated with this XASession. * @@ -192,4 +190,11 @@ public class XASessionImpl extends AMQSession_0_10 implements XASession, XATopic super.acknowledgeImpl() ; } } + + @Override + void resubscribe() throws AMQException + { + super.resubscribe(); + createSession(); + } } |