You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@commons.apache.org by js...@apache.org on 2002/11/08 16:26:00 UTC
cvs commit: jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messagelet XAConsumerThread.java
jstrachan 2002/11/08 07:26:00
Modified: messenger/src/java/org/apache/commons/messagelet
XAConsumerThread.java
Log:
Minor patch to XA support - so that by default Bridge MDOs will work with XA if they have XA connections
Revision Changes Path
1.2 +12 -0 jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messagelet/XAConsumerThread.java
Index: XAConsumerThread.java
===================================================================
RCS file: /home/cvs/jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messagelet/XAConsumerThread.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- XAConsumerThread.java 8 Nov 2002 14:54:26 -0000 1.1
+++ XAConsumerThread.java 8 Nov 2002 15:26:00 -0000 1.2
@@ -93,6 +93,12 @@
xaCapable = (XACapable) listener;
xaCapable.enlistResources(transaction);
}
+
+ if (listener instanceof BridgeMDO) {
+ BridgeMDO bridge = (BridgeMDO) listener;
+ xaCapable = getXACapable( bridge.getOutputMessenger() );
+ xaCapable.enlistResources(transaction);
+ }
}
@@ -115,6 +121,12 @@
MessageListener listener = getListener();
if (listener instanceof XACapable) {
xaCapable = (XACapable) listener;
+ xaCapable.delistResources(transaction, flag);
+ }
+
+ if (listener instanceof BridgeMDO) {
+ BridgeMDO bridge = (BridgeMDO) listener;
+ xaCapable = getXACapable( bridge.getOutputMessenger() );
xaCapable.delistResources(transaction, flag);
}
}
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>