commons-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject cvs commit: jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messagelet XAConsumerThread.java
Date Fri, 08 Nov 2002 15:26:00 GMT
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:   <mailto:commons-dev-unsubscribe@jakarta.apache.org>
For additional commands, e-mail: <mailto:commons-dev-help@jakarta.apache.org>


Mime
View raw message