[jboss-svn-commits] JBL Code SVN: r20514 - labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/wst11/messaging.

[jboss-svn-commits at lists.jboss.org]

Author: adinn
Date: 2008-06-16 06:14:37 -0400 (Mon, 16 Jun 2008)
New Revision: 20514

Modified:
   labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/wst11/messaging/ParticipantProcessorImpl.java
Log:
ensured that participant responds to commit or rollback with committed or aborted, respectively, when it has no endpoint. this is required to implement assumed commit for incoming commit and assumed abort for incoming rollback which may happen during recovery

Modified: labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/wst11/messaging/ParticipantProcessorImpl.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/wst11/messaging/ParticipantProcessorImpl.java	2008-06-16 09:09:48 UTC (rev 20513)
+++ labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/wst11/messaging/ParticipantProcessorImpl.java	2008-06-16 10:14:37 UTC (rev 20514)
@@ -8,6 +8,7 @@
 import com.arjuna.webservices11.wsarj.InstanceIdentifier;
 import com.arjuna.webservices11.wsat.processors.ParticipantProcessor;
 import com.arjuna.webservices11.wsat.ParticipantInboundEvents;
+import com.arjuna.webservices11.wsat.client.CoordinatorClient;
 import com.arjuna.wsc11.messaging.MessageId;
 import org.oasis_open.docs.ws_tx.wsat._2006._06.Notification;
 
@@ -223,11 +224,9 @@
         final String messageId = MessageId.getMessageId() ;
         final AddressingProperties responseAddressingProperties = AddressingHelper.createResponseContext(addressingProperties, messageId) ;
         final InstanceIdentifier instanceIdentifier = arjunaContext.getInstanceIdentifier() ;
-        /*
-         * TODO - fix this. participant is null and we cannto send a message without an endpoint
         try
         {
-            CoordinatorClient.getClient().sendCommitted(responseAddressingProperties, instanceIdentifier) ;
+            CoordinatorClient.getClient().sendCommitted(null, responseAddressingProperties, instanceIdentifier) ;
         }
         catch (final Throwable th)
         {
@@ -236,7 +235,6 @@
                 WSTLogger.arjLoggerI18N.debug("com.arjuna.wst11.messaging.ParticipantProcessorImpl.sendCommitted_1", th) ;
             }
         }
-        */
     }
 
     /**
@@ -253,11 +251,9 @@
         final String messageId = MessageId.getMessageId() ;
         final AddressingProperties responseAddressingProperties = AddressingHelper.createResponseContext(addressingProperties, messageId) ;
         final InstanceIdentifier instanceIdentifier = arjunaContext.getInstanceIdentifier() ;
-        /*
-         * TODO - fix this. participant is null and we cannto send a message without an endpoint
         try
         {
-            CoordinatorClient.getClient().sendAborted(responseAddressingProperties, instanceIdentifier) ;
+            CoordinatorClient.getClient().sendAborted(null, responseAddressingProperties, instanceIdentifier) ;
         }
         catch (final Throwable th)
         {
@@ -266,6 +262,5 @@
                 WSTLogger.arjLoggerI18N.debug("com.arjuna.wst11.messaging.ParticipantProcessorImpl.sendAborted_1", th) ;
             }
         }
-        */
     }
 }