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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
