[jboss-svn-commits] JBL Code SVN: r19695 - in labs/jbosstm/trunk/XTS: WS-C/dev/src11/com/arjuna/webservices11/wsaddr/processor and 1 other directories.

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

Author: adinn
Date: 2008-04-23 05:54:14 -0400 (Wed, 23 Apr 2008)
New Revision: 19695

Added:
   labs/jbosstm/trunk/XTS/WS-C/dev/src11/com/arjuna/webservices11/wsaddr/processor/
   labs/jbosstm/trunk/XTS/WS-C/dev/src11/com/arjuna/webservices11/wsaddr/processor/BaseWSAddrResponseProcessor.java
Modified:
   labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/wst11/messaging/engines/ParticipantEngine.java
Log:
additions to allow WSTX11 interop tests to run

Copied: labs/jbosstm/trunk/XTS/WS-C/dev/src11/com/arjuna/webservices11/wsaddr/processor/BaseWSAddrResponseProcessor.java (from rev 19592, labs/jbosstm/trunk/XTS/WS-C/dev/src10/com/arjuna/webservices/wsaddr/processor/BaseWSAddrResponseProcessor.java)
===================================================================
--- labs/jbosstm/trunk/XTS/WS-C/dev/src11/com/arjuna/webservices11/wsaddr/processor/BaseWSAddrResponseProcessor.java	                        (rev 0)
+++ labs/jbosstm/trunk/XTS/WS-C/dev/src11/com/arjuna/webservices11/wsaddr/processor/BaseWSAddrResponseProcessor.java	2008-04-23 09:54:14 UTC (rev 19695)
@@ -0,0 +1,53 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. 
+ * See the copyright.txt in the distribution for a full listing 
+ * of individual contributors.
+ * This copyrighted material is made available to anyone wishing to use,
+ * modify, copy, or redistribute it subject to the terms and conditions
+ * of the GNU General Public License, v. 2.0.
+ * This program is distributed in the hope that it will be useful, but WITHOUT A 
+ * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A 
+ * PARTICULAR PURPOSE.  See the GNU General Public License for more details.
+ * You should have received a copy of the GNU General Public License,
+ * v. 2.0 along with this distribution; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, 
+ * MA  02110-1301, USA.
+ * 
+ * (C) 2005-2006,
+ * @author JBoss Inc.
+ */
+package com.arjuna.webservices11.wsaddr.processor;
+
+import com.arjuna.webservices.base.processors.BaseProcessor;
+import javax.xml.ws.addressing.AddressingProperties;
+import javax.xml.ws.addressing.Relationship;
+
+/**
+ * Utility class handling common response functionality.
+ * @author kevin
+ */
+public abstract class BaseWSAddrResponseProcessor extends BaseProcessor
+{
+    /**
+     * Get the callback ids.
+     * @param addressingProperties The addressing context.
+     * @return The callback ids.
+     */
+    protected String[] getIDs(final AddressingProperties addressingProperties)
+    {
+        final Relationship[] relationships = addressingProperties.getRelatesTo() ;
+        if (relationships != null)
+        {
+            final int numRelationships = relationships.length ;
+            final String[] ids = new String[numRelationships] ;
+            for(int count = 0 ; count < numRelationships ; count++)
+            {
+                ids[count] = relationships[count].getID().toString();
+            }
+            return ids ;
+        }
+        return null ;
+    }
+}
\ No newline at end of file

Modified: labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/wst11/messaging/engines/ParticipantEngine.java
===================================================================
--- labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/wst11/messaging/engines/ParticipantEngine.java	2008-04-23 07:08:47 UTC (rev 19694)
+++ labs/jbosstm/trunk/XTS/WS-T/dev/src11/com/arjuna/wst11/messaging/engines/ParticipantEngine.java	2008-04-23 09:54:14 UTC (rev 19695)
@@ -204,6 +204,60 @@
     }
 
     /**
+     * Handle the early rollback event.
+     *
+     * None -> None
+     * Active -> Aborting (execute rollback, send aborted and forget)
+     * Preparing -> Aborting (execute rollback, send aborted and forget)
+     * PreparedSuccess -> PreparedSuccess
+     * Committing -> Committing
+     * Aborting -> Aborting
+     */
+    public void earlyRollback()
+    {
+        rollbackDecision() ;
+    }
+
+    /**
+     * Handle the early readonly event.
+     *
+     * None -> None
+     * Active -> None (send ReadOnly)
+     * Preparing -> None (send ReadOnly)
+     * PreparedSuccess -> PreparedSuccess
+     * Committing -> Committing
+     * Aborting -> Aborting
+     */
+    public void earlyReadonly()
+    {
+        readOnlyDecision() ;
+    }
+
+    /**
+     * Handle the recovery event.
+     *
+     * None -> None
+     * Active -> Active
+     * Preparing -> Preparing
+     * Committing -> Committing
+     * PreparedSuccess -> PreparedSuccess (resend Prepared)
+     * Aborting -> Aborting
+     */
+    public void recovery()
+    {
+        final State current ;
+        synchronized(this)
+        {
+            current = state ;
+        }
+
+        if (current == State.STATE_PREPARED_SUCCESS)
+        {
+            sendPrepared() ;
+        }
+    }
+
+    /**
      * Handle the soap fault event.
      * @param soapFault The soap fault.
      * @param addressingProperties The addressing context.