From 319f195a7377f8b5848375bbde1e6353cc6822b1 Mon Sep 17 00:00:00 2001 From: "Weston M. Price" Date: Mon, 11 Jun 2012 12:42:26 +0000 Subject: QPID-4034: XASessionImpl should override resubscribe() for correct XA failover behavior *Implemented resubscribe() in XASessionImpl *Minor cleanup, fixed typos etc git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1348825 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/client/XASessionImpl.java | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) (limited to 'qpid/java/client') 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(); + } } -- cgit v1.2.1