You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by th...@apache.org on 2005/09/25 21:37:37 UTC

svn commit: r291467 [2/2] - in /webservices/kandula/trunk/java: src/org/apache/kandula/ src/org/apache/kandula/context/at/ src/org/apache/kandula/context/coordination/ src/org/apache/kandula/initiator/ src/org/apache/kandula/utility/ src/org/apache/kan...

Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationRequesterPortTypeRawXMLSkeleton.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationRequesterPortTypeRawXMLSkeleton.java?rev=291467&r1=291466&r2=291467&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationRequesterPortTypeRawXMLSkeleton.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationRequesterPortTypeRawXMLSkeleton.java Sun Sep 25 12:36:21 2005
@@ -1,7 +1,14 @@
 package org.apache.kandula.wscoor;
 
+import org.apache.axis2.addressing.EndpointReference;
 import org.apache.axis2.context.MessageContext;
 import org.apache.axis2.om.OMElement;
+import org.apache.kandula.context.AbstractContext;
+import org.apache.kandula.context.at.ATActivityContext;
+import org.apache.kandula.context.coordination.CoordinationContext;
+import org.apache.kandula.initiator.TransactionManager;
+import org.apache.kandula.storage.StorageFactory;
+import org.apache.kandula.utility.KandulaUtils;
 
 /*
  * Copyright 2004,2005 The Apache Software Foundation.
@@ -32,16 +39,13 @@
         this.msgContext = context;
     }
 
-    public OMElement RegisterOperation(OMElement requestElement) {
-//        OMElement coordinationContextElement = requestElement
-//                .getFirstChildWithName(new QName("CoordinationContext"));
-//        if ("CoordinationContext".equals(requestElement.getLocalName()))
-//        {
-//        msgContext.getMessageInformationHeaders().getReferenceParameters();
-//        CoordinationContext  coordinationContext  =CoordinationContext.Factory.newInstance(requestElement);
-//        ActivityContext context = StorageFactory.getInstance().getStore().getContext(TransactionManager.tempID);
-//        context.setCoordinationContext(coordinationContext);
-//        }
+    public OMElement registerResponseOperation(OMElement responseElement) {
+        OMElement response = responseElement.getFirstElement();
+        if ("CoordinatorProtocolService".equals(response.getLocalName())) {
+            EndpointReference coordinatorService  = KandulaUtils.endpointFromOM(response.getFirstElement());
+            AbstractContext context = (AbstractContext)StorageFactory.getInstance().getStore().get(TransactionManager.tempID);
+            context.setProperty(ATActivityContext.COORDINATION_EPR,coordinatorService);
+        }
         return null;
     }
 }

Added: webservices/kandula/trunk/java/test-resources/testing-repository/services/ActivationCoordinator/META-INF/services.xml
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/test-resources/testing-repository/services/ActivationCoordinator/META-INF/services.xml?rev=291467&view=auto
==============================================================================
--- webservices/kandula/trunk/java/test-resources/testing-repository/services/ActivationCoordinator/META-INF/services.xml (added)
+++ webservices/kandula/trunk/java/test-resources/testing-repository/services/ActivationCoordinator/META-INF/services.xml Sun Sep 25 12:36:21 2005
@@ -0,0 +1,10 @@
+<service name="ActivationCoordinator">
+    <description>
+        Coordination service.
+    </description>
+    <parameter name="ServiceClass" locked="xsd:false">org.apache.kandula.wscoor.ActivationPortTypeRawXMLSkeleton</parameter>
+    <operation name="createCoordinationContextOperation">
+        <parameter name="wsamapping" locked="xsd:false">http://schemas.xmlsoap.org/ws/2004/10/wscoor/CreateCoordinationContext</parameter>
+        <messageReceiver class="org.apache.kandula.wscoor.ActivationPortTypeRawXMLAsyncMessageReceiver"/>
+    </operation>
+</service>

Added: webservices/kandula/trunk/java/test-resources/testing-repository/services/RegistrationCoordinator/META-INF/services.xml
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/test-resources/testing-repository/services/RegistrationCoordinator/META-INF/services.xml?rev=291467&view=auto
==============================================================================
--- webservices/kandula/trunk/java/test-resources/testing-repository/services/RegistrationCoordinator/META-INF/services.xml (added)
+++ webservices/kandula/trunk/java/test-resources/testing-repository/services/RegistrationCoordinator/META-INF/services.xml Sun Sep 25 12:36:21 2005
@@ -0,0 +1,10 @@
+<service name="RegistrationCoordinator">
+    <description>
+        Coordination service.
+    </description>
+    <parameter name="ServiceClass" locked="xsd:false">org.apache.kandula.wscoor.RegistrationPortTypeRawXMLSkeleton</parameter>
+    <operation name="registerOperation">
+        <parameter name="wsamapping" locked="xsd:false">http://schemas.xmlsoap.org/ws/2004/10/wscoor/Register</parameter>
+        <messageReceiver class="org.apache.kandula.wscoor.RegistrationPortTypeRawXMLAsyncMessageReceiver"/>
+    </operation>
+</service>



---------------------------------------------------------------------
To unsubscribe, e-mail: kandula-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: kandula-dev-help@ws.apache.org