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/10/02 14:28:54 UTC
svn commit: r293101 [2/2] - in /webservices/kandula/trunk/java: ./
src/org/apache/kandula/ src/org/apache/kandula/context/
src/org/apache/kandula/context/at/
src/org/apache/kandula/context/coordination/
src/org/apache/kandula/coordinator/ src/org/apach...
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/utility/KandulaListener.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/utility/KandulaListener.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/utility/KandulaListener.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/utility/KandulaListener.java Sun Oct 2 05:26:06 2005
@@ -16,23 +16,15 @@
*/
package org.apache.kandula.utility;
+import java.io.IOException;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+
import org.apache.axis2.AxisFault;
import org.apache.axis2.context.ConfigurationContext;
-import org.apache.axis2.description.OperationDescription;
-import org.apache.axis2.description.Parameter;
-import org.apache.axis2.description.ParameterImpl;
import org.apache.axis2.description.ServiceDescription;
-import org.apache.axis2.receivers.AbstractMessageReceiver;
-import org.apache.axis2.receivers.RawXMLINOnlyMessageReceiver;
import org.apache.axis2.transport.http.SimpleHTTPServer;
import org.apache.axis2.util.Utils;
-import org.apache.kandula.Constants;
-import org.apache.wsdl.WSDLService;
-
-import javax.xml.namespace.QName;
-import java.io.IOException;
-import java.net.InetAddress;
-import java.net.UnknownHostException;
/**
* @author <a href="mailto:thilina@opensource.lk"> Thilina Gunarathne </a>
@@ -84,12 +76,13 @@
/**
* @param serviceName
* @param operationName
- * @throws AxisFault To add services with only one operation, which is the
- * frequent case in reponses
+ * @throws AxisFault
+ * To add services with only one operation, which is the
+ * frequent case in reponses
*/
public void addService(ServiceDescription service) throws AxisFault {
org.apache.axis2.description.OperationDescription responseOperationDesc;
-
+
service.setClassLoader(Thread.currentThread().getContextClassLoader());
responseConfigurationContext.getAxisConfiguration().addService(service);
@@ -98,7 +91,7 @@
}
public String getHost() throws UnknownHostException {
- return "http://" + InetAddress.getLocalHost().getHostAddress() + ":" + SERVER_PORT
- + "/axis2/services/";
+ return "http://" + InetAddress.getLocalHost().getHostAddress() + ":"
+ + SERVER_PORT + "/axis2/services/";
}
}
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/utility/KandulaUtils.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/utility/KandulaUtils.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/utility/KandulaUtils.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/utility/KandulaUtils.java Sun Oct 2 05:26:06 2005
@@ -16,15 +16,6 @@
*/
package org.apache.kandula.utility;
-import org.apache.axis2.addressing.AddressingConstants;
-import org.apache.axis2.addressing.AddressingConstants.Final;
-import org.apache.axis2.addressing.AnyContentType;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.om.OMElement;
-import org.apache.axis2.om.OMNamespace;
-import org.apache.axis2.soap.SOAPFactory;
-
-import javax.xml.namespace.QName;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.security.MessageDigest;
@@ -32,12 +23,23 @@
import java.util.Iterator;
import java.util.Random;
+import javax.xml.namespace.QName;
+
+import org.apache.axis2.addressing.AddressingConstants;
+import org.apache.axis2.addressing.AnyContentType;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.addressing.AddressingConstants.Final;
+import org.apache.axis2.om.OMElement;
+import org.apache.axis2.om.OMNamespace;
+import org.apache.axis2.soap.SOAPFactory;
+
/**
* @author <a href="mailto:thilina@opensource.lk"> Thilina Gunarathne </a>
*/
public class KandulaUtils {
-
- public static void endpointToOM(EndpointReference epr, OMElement parentEPR, SOAPFactory factory) {
+
+ public static void endpointToOM(EndpointReference epr, OMElement parentEPR,
+ SOAPFactory factory) {
OMNamespace wsAddressing = factory.createOMNamespace(
AddressingConstants.Submission.WSA_NAMESPACE,
AddressingConstants.WSA_DEFAULT_PRFIX);
@@ -66,12 +68,11 @@
}
}
}
-
- public static EndpointReference endpointFromOM(OMElement eprElement)
- {
+
+ public static EndpointReference endpointFromOM(OMElement eprElement) {
EndpointReference epr;
- epr = new EndpointReference(eprElement
- .getFirstChildWithName(new QName("Address")).getText());
+ epr = new EndpointReference(eprElement.getFirstChildWithName(
+ new QName("Address")).getText());
AnyContentType referenceProperties = new AnyContentType();
OMElement referencePropertiesElement = eprElement
.getFirstChildWithName(new QName("ReferenceProperties"));
@@ -88,7 +89,7 @@
/**
* MD5 a random string with localhost/date etc will return 128 bits
* construct a string of 18 characters from those bits.
- *
+ *
* @return string
*/
public static String getRandomStringOf18Characters() {
@@ -122,8 +123,10 @@
sb2.append(Integer.toHexString(b));
}
int begin = myRand.nextInt();
- if (begin < 0) begin = begin * -1;
+ if (begin < 0)
+ begin = begin * -1;
begin = begin % 8;
- return new String(sb2.toString().substring(begin, begin + 18)).toUpperCase();
+ return new String(sb2.toString().substring(begin, begin + 18))
+ .toUpperCase();
}
-}
+}
\ No newline at end of file
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/AbstractATNotifierStub.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/AbstractATNotifierStub.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/AbstractATNotifierStub.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/AbstractATNotifierStub.java Sun Oct 2 05:26:06 2005
@@ -18,6 +18,7 @@
import java.io.IOException;
+import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.clientapi.MessageSender;
import org.apache.axis2.clientapi.Stub;
@@ -25,34 +26,59 @@
import org.apache.axis2.om.OMElement;
import org.apache.axis2.om.OMNamespace;
import org.apache.kandula.Constants;
+import org.apache.kandula.faults.AbstractKandulaException;
+import org.apache.kandula.faults.KandulaGeneralException;
/**
* @author <a href="mailto:thilina@opensource.lk"> Thilina Gunarathne </a>
*/
public abstract class AbstractATNotifierStub extends Stub {
protected static org.apache.axis2.description.OperationDescription[] operations;
+
public AbstractATNotifierStub() {
super();
}
+
+ /**
+ * Provides common functionality for stubs to send notification messages
+ *
+ * @param localName :
+ * name of the notification message
+ * @param action :
+ * ws-a action value for the notification message
+ * @param opIndex :
+ * operation index in the operations array
+ * @param replyToEPR :
+ * notification messages except termination messages should send
+ * this
+ * @throws IOException
+ */
protected void notify(String localName, String action, int opIndex,
- EndpointReference replyToEPR) throws IOException {
- org.apache.axis2.context.MessageContext messageContext = getMessageContext();
- org.apache.axis2.soap.SOAPEnvelope env = super.createEnvelope();
- org.apache.axis2.soap.SOAPFactory factory = OMAbstractFactory
- .getSOAP12Factory();
- OMNamespace wsAT = factory.createOMNamespace(Constants.WS_AT, "wsat");
- OMElement request = factory.createOMElement(localName, wsAT);
- env.getBody().addChild(request);
- messageContext.setEnvelope(env);
+ EndpointReference replyToEPR) throws AbstractKandulaException {
+ org.apache.axis2.context.MessageContext messageContext;
+ try {
+ messageContext = getMessageContext();
+
+ org.apache.axis2.soap.SOAPEnvelope env = super.createEnvelope();
+ org.apache.axis2.soap.SOAPFactory factory = OMAbstractFactory
+ .getSOAP12Factory();
+ OMNamespace wsAT = factory.createOMNamespace(Constants.WS_AT,
+ "wsat");
+ OMElement request = factory.createOMElement(localName, wsAT);
+ env.getBody().addChild(request);
+ messageContext.setEnvelope(env);
- MessageSender messageSender = new MessageSender(_serviceContext);
- messageSender.setTo(this.toEPR);
- if (replyToEPR != null) {
- messageSender.setReplyTo(replyToEPR);
+ MessageSender messageSender = new MessageSender(_serviceContext);
+ messageSender.setTo(this.toEPR);
+ if (replyToEPR != null) {
+ messageSender.setReplyTo(replyToEPR);
+ }
+ messageSender.setWsaAction(action);
+ messageSender
+ .setSenderTransport(org.apache.axis2.Constants.TRANSPORT_HTTP);
+ messageSender.send(operations[opIndex], messageContext);
+ } catch (AxisFault e) {
+ throw new KandulaGeneralException(e);
}
- messageSender.setWsaAction(action);
- messageSender
- .setSenderTransport(org.apache.axis2.Constants.TRANSPORT_HTTP);
- messageSender.send(operations[opIndex], messageContext);
}
-}
+}
\ No newline at end of file
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionCoordinatorPortTypeRawXMLSkeleton.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionCoordinatorPortTypeRawXMLSkeleton.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionCoordinatorPortTypeRawXMLSkeleton.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionCoordinatorPortTypeRawXMLSkeleton.java Sun Oct 2 05:26:06 2005
@@ -1,12 +1,10 @@
package org.apache.kandula.wsat.completion;
-import javax.xml.namespace.QName;
-
import org.apache.axis2.AxisFault;
-import org.apache.axis2.context.MessageContext;
import org.apache.axis2.om.OMElement;
import org.apache.kandula.context.AbstractContext;
import org.apache.kandula.coordinator.Coordinator;
+import org.apache.kandula.coordinator.at.ATCoordinator;
import org.apache.kandula.faults.AbstractKandulaException;
/**
@@ -17,76 +15,40 @@
/**
* @param requestElement
- * @throws AbstractKandulaException
+ * @throws AxisFault
*/
public OMElement commitOperation(OMElement requestElement) throws AxisFault {
AbstractContext context;
+ String activityId;
System.out.println("Visited Commit operation");
- // /*
- // * Extracting data from the incoming message
- // */
- // String coordinationType = requestElement.getFirstChildWithName(
- // new QName("CoordinationType")).getText();
- // OMElement expiresElement = requestElement
- // .getFirstChildWithName(new QName("Expires"));
- // String expires = null;
- // long expiresL = 0;
- // if (expiresElement != null) {
- // expires = expiresElement.getText();
- // if ((expires != null) && (expires.equals(""))) {
- // expiresL = Long.parseLong(expires);
- // }
- // }
- //
- // /*
- // * Creating the Coordination Context
- // */
- // try {
- // Coordinator coordinator = new Coordinator();
- // context = coordinator.createCoordinationContext(coordinationType,
- // expiresL);
- // return context.getCoordinationContext().toOM();
- // } catch (AbstractKandulaException e) {
- // AxisFault fault = new AxisFault(e);
- // fault.setFaultCode(e.getFaultCode());
- // throw fault;
- // }
+ activityId = Coordinator.ACTIVITY_ID;
+
+ // TODO do we need to check the incoming message
+ try {
+ ATCoordinator coordinator = new ATCoordinator();
+ coordinator.commitOperation(activityId);
+ } catch (AbstractKandulaException e) {
+ AxisFault fault = new AxisFault(e);
+ fault.setFaultCode(e.getFaultCode());
+ throw fault;
+ }
return null;
}
public OMElement rollbackOperation(OMElement requestElement)
throws AxisFault {
AbstractContext context;
- System.out.println("Visited Commit operation");
- ///*
- // * Extracting data from the incoming message
- // */
- //String coordinationType = requestElement.getFirstChildWithName(
- // new QName("CoordinationType")).getText();
- //OMElement expiresElement = requestElement
- // .getFirstChildWithName(new QName("Expires"));
- //String expires = null;
- //long expiresL = 0;
- //if (expiresElement != null) {
- // expires = expiresElement.getText();
- // if ((expires != null) && (expires.equals(""))) {
- // expiresL = Long.parseLong(expires);
- // }
- //}
- //
- ///*
- // * Creating the Coordination Context
- // */
- //try {
- // Coordinator coordinator = new Coordinator();
- // context = coordinator.createCoordinationContext(coordinationType,
- // expiresL);
- // return context.getCoordinationContext().toOM();
- //} catch (AbstractKandulaException e) {
- // AxisFault fault = new AxisFault(e);
- // fault.setFaultCode(e.getFaultCode());
- // throw fault;
- //}
+ String activityId;
+ System.out.println("Visited rollback operation");
+ activityId = Coordinator.ACTIVITY_ID;
+ try {
+ ATCoordinator coordinator = new ATCoordinator();
+ coordinator.commitOperation(activityId);
+ } catch (AbstractKandulaException e) {
+ AxisFault fault = new AxisFault(e);
+ fault.setFaultCode(e.getFaultCode());
+ throw fault;
+ }
return null;
}
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionCoordinatorPortTypeRawXMLStub.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionCoordinatorPortTypeRawXMLStub.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionCoordinatorPortTypeRawXMLStub.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionCoordinatorPortTypeRawXMLStub.java Sun Oct 2 05:26:06 2005
@@ -1,14 +1,9 @@
package org.apache.kandula.wsat.completion;
-import java.io.IOException;
-
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.clientapi.MessageSender;
-import org.apache.axis2.om.OMAbstractFactory;
-import org.apache.axis2.om.OMElement;
-import org.apache.axis2.om.OMNamespace;
import org.apache.kandula.Constants;
+import org.apache.kandula.faults.AbstractKandulaException;
import org.apache.kandula.wsat.AbstractATNotifierStub;
public class CompletionCoordinatorPortTypeRawXMLStub extends
@@ -41,6 +36,7 @@
/**
* Constructor
+ *
* @throws AxisFault
*/
public CompletionCoordinatorPortTypeRawXMLStub(String axis2Home,
@@ -55,13 +51,13 @@
_service.getName().getLocalPart());
}
- public void commitOperation() throws IOException {
+ public void commitOperation() throws AbstractKandulaException {
//TODO must send reply to epr
this.notify("Commit", Constants.WS_AT_COMMIT, 0, null);
}
- public void rollbackOperation() throws IOException {
+ public void rollbackOperation() throws AbstractKandulaException {
//TODO must send reply to EPR
this.notify("Rollback", Constants.WS_AT_ROLLBACK, 1, null);
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionInitiatorPortTypeRawXMLSkeleton.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionInitiatorPortTypeRawXMLSkeleton.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionInitiatorPortTypeRawXMLSkeleton.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionInitiatorPortTypeRawXMLSkeleton.java Sun Oct 2 05:26:06 2005
@@ -2,10 +2,10 @@
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.om.OMElement;
+import org.apache.kandula.Status;
import org.apache.kandula.context.AbstractContext;
import org.apache.kandula.initiator.TransactionManager;
import org.apache.kandula.storage.StorageFactory;
-import org.apache.kandula.context.coordination.CoordinationContext;
/*
* Copyright 2004,2005 The Apache Software Foundation.
@@ -37,21 +37,24 @@
}
public OMElement committedOperation(OMElement requestElement) {
- if ("CoordinationContext".equals(requestElement.getLocalName())) {
- msgContext.getMessageInformationHeaders().getReferenceParameters();
- CoordinationContext coordinationContext = CoordinationContext.Factory.newContext(requestElement);
- AbstractContext context = (AbstractContext)StorageFactory.getInstance().getStore().get(TransactionManager.tempID);
- // context.setCoordinationContext(coordinationContext);
- }
+ //TODO use refrence parameters for this
+ //Have to wait till Axis2 Addressing get this correctly
+ //String requesterID ;
+
+ AbstractContext context = (AbstractContext) StorageFactory
+ .getInstance().getStore().get(TransactionManager.tempID);
+ context.setStatus(Status.ParticipantStatus.STATUS_COMMITED);
return null;
}
+
public OMElement abortedOperation(OMElement requestElement) {
- if ("CoordinationContext".equals(requestElement.getLocalName())) {
- msgContext.getMessageInformationHeaders().getReferenceParameters();
- CoordinationContext coordinationContext = CoordinationContext.Factory.newContext(requestElement);
- AbstractContext context = (AbstractContext)StorageFactory.getInstance().getStore().get(TransactionManager.tempID);
- //context.setCoordinationContext(coordinationContext);
- }
+ // TODO use refrence parameters for this
+ //Have to wait till Axis2 Addressing get this correctly
+ //String requesterID ;
+
+ AbstractContext context = (AbstractContext) StorageFactory
+ .getInstance().getStore().get(TransactionManager.tempID);
+ context.setStatus(Status.ParticipantStatus.STATUS_ABORTED);
return null;
}
}
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionInitiatorPortTypeRawXMLStub.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionInitiatorPortTypeRawXMLStub.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionInitiatorPortTypeRawXMLStub.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionInitiatorPortTypeRawXMLStub.java Sun Oct 2 05:26:06 2005
@@ -1,9 +1,11 @@
package org.apache.kandula.wsat.completion;
-import java.io.IOException;
-
+import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.deployment.DeploymentException;
import org.apache.kandula.Constants;
+import org.apache.kandula.faults.AbstractKandulaException;
+import org.apache.kandula.faults.KandulaGeneralException;
import org.apache.kandula.wsat.AbstractATNotifierStub;
public class CompletionInitiatorPortTypeRawXMLStub extends
@@ -36,24 +38,32 @@
/**
* Constructor
+ *
+ * @throws AbstractKandulaException
*/
public CompletionInitiatorPortTypeRawXMLStub(String axis2Home,
- EndpointReference targetEndpoint) throws java.lang.Exception {
+ EndpointReference targetEndpoint) throws AbstractKandulaException {
this.toEPR = targetEndpoint;
- //creating the configuration
- _configurationContext = new org.apache.axis2.context.ConfigurationContextFactory()
- .buildClientConfigurationContext(axis2Home);
- _configurationContext.getAxisConfiguration().addService(_service);
+ try {
+ //creating the configuration
+ _configurationContext = new org.apache.axis2.context.ConfigurationContextFactory()
+ .buildClientConfigurationContext(axis2Home);
+ _configurationContext.getAxisConfiguration().addService(_service);
+ } catch (DeploymentException e) {
+ throw new KandulaGeneralException(e);
+ } catch (AxisFault e1) {
+ throw new KandulaGeneralException(e1);
+ }
_serviceContext = _service.getParent().getServiceGroupContext(
_configurationContext).getServiceContext(
_service.getName().getLocalPart());
}
- public void committedOperation() throws IOException {
+ public void committedOperation() throws AbstractKandulaException {
this.notify("Committed", Constants.WS_AT_COMMITTED, 0, null);
}
- public void abortedOperation() throws IOException {
+ public void abortedOperation() throws AbstractKandulaException {
this.notify("Aborted", Constants.WS_AT_ABORTED, 1, null);
}
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionInitiatorServiceListener.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionInitiatorServiceListener.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionInitiatorServiceListener.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/completion/CompletionInitiatorServiceListener.java Sun Oct 2 05:26:06 2005
@@ -34,7 +34,8 @@
public class CompletionInitiatorServiceListener {
private static CompletionInitiatorServiceListener instance = null;
- private EndpointReference epr=null;
+
+ private EndpointReference epr = null;
private CompletionInitiatorServiceListener() {
super();
@@ -47,14 +48,13 @@
return instance;
}
- public EndpointReference getEpr() throws IOException
- {
- if (epr==null)
- {
+ public EndpointReference getEpr() throws IOException {
+ if (epr == null) {
this.epr = setupListener();
}
return this.epr;
}
+
private EndpointReference setupListener() throws IOException {
QName serviceName = new QName("CompletionInitiatorPortType");
String className = CompletionInitiatorPortTypeRawXMLSkeleton.class
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/CoordinatorPortTypeRawXMLSkeleton.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/CoordinatorPortTypeRawXMLSkeleton.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/CoordinatorPortTypeRawXMLSkeleton.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/CoordinatorPortTypeRawXMLSkeleton.java Sun Oct 2 05:26:06 2005
@@ -1,50 +1,73 @@
package org.apache.kandula.wsat.twopc;
-import javax.xml.namespace.QName;
-
import org.apache.axis2.AxisFault;
-import org.apache.axis2.context.MessageContext;
import org.apache.axis2.om.OMElement;
import org.apache.kandula.context.AbstractContext;
import org.apache.kandula.coordinator.Coordinator;
+import org.apache.kandula.coordinator.at.ATCoordinator;
import org.apache.kandula.faults.AbstractKandulaException;
+import org.apache.kandula.participant.Vote;
/**
* Auto generated java skeleton for the service by the Axis code generator
*/
public class CoordinatorPortTypeRawXMLSkeleton {
-
+
/**
* @param requestElement
* @throws AbstractKandulaException
*/
public OMElement preparedOperation(OMElement requestElement)
throws AxisFault {
- AbstractContext context;
- System.out.println("Visited Commit operation");
+ String activityId = Coordinator.ACTIVITY_ID;
+ ATCoordinator coordinator= new ATCoordinator();
+ try {
+ coordinator.countVote(activityId,Vote.PREPARED,null);
+ } catch (AbstractKandulaException e) {
+ AxisFault fault = new AxisFault(e);
+ fault.setFaultCode(e.getFaultCode());
+ throw fault;
+ }
return null;
}
+
/**
* @param requestElement
* @throws AbstractKandulaException
*/
public OMElement abortedOperation(OMElement requestElement)
throws AxisFault {
- AbstractContext context;
- System.out.println("Visited Commit operation");
+ String activityId = Coordinator.ACTIVITY_ID;
+ ATCoordinator coordinator= new ATCoordinator();
+ try {
+ coordinator.countVote(activityId,Vote.ABORT,null);
+ } catch (AbstractKandulaException e) {
+ AxisFault fault = new AxisFault(e);
+ fault.setFaultCode(e.getFaultCode());
+ throw fault;
+ }
return null;
}
+
/**
* @param requestElement
* @throws AbstractKandulaException
*/
public OMElement readOnlyOperation(OMElement requestElement)
throws AxisFault {
- AbstractContext context;
- System.out.println("Visited Commit operation");
+ String activityId = Coordinator.ACTIVITY_ID;
+ ATCoordinator coordinator= new ATCoordinator();
+ try {
+ coordinator.countVote(activityId,Vote.READ_ONLY,null);
+ } catch (AbstractKandulaException e) {
+ AxisFault fault = new AxisFault(e);
+ fault.setFaultCode(e.getFaultCode());
+ throw fault;
+ }
return null;
}
+
/**
* @param requestElement
* @throws AbstractKandulaException
@@ -55,12 +78,12 @@
System.out.println("Visited Commit operation");
return null;
}
+
/**
* @param requestElement
* @throws AbstractKandulaException
*/
- public OMElement replayOperation(OMElement requestElement)
- throws AxisFault {
+ public OMElement replayOperation(OMElement requestElement) throws AxisFault {
AbstractContext context;
System.out.println("Visited Commit operation");
return null;
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/CoordinatorPortTypeRawXMLStub.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/CoordinatorPortTypeRawXMLStub.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/CoordinatorPortTypeRawXMLStub.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/CoordinatorPortTypeRawXMLStub.java Sun Oct 2 05:26:06 2005
@@ -1,13 +1,8 @@
package org.apache.kandula.wsat.twopc;
-import java.io.IOException;
-
import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.clientapi.MessageSender;
-import org.apache.axis2.om.OMAbstractFactory;
-import org.apache.axis2.om.OMElement;
-import org.apache.axis2.om.OMNamespace;
import org.apache.kandula.Constants;
+import org.apache.kandula.faults.AbstractKandulaException;
import org.apache.kandula.wsat.AbstractATNotifierStub;
public class CoordinatorPortTypeRawXMLStub extends AbstractATNotifierStub {
@@ -68,26 +63,26 @@
_service.getName().getLocalPart());
}
- public void preparedOperation() throws IOException {
+ public void preparedOperation() throws AbstractKandulaException {
// must send reply to epr
this.notify("Prepared", Constants.WS_AT_PREPARED, 0, null);
}
- public void abortedOperation() throws IOException {
+ public void abortedOperation() throws AbstractKandulaException {
this.notify("Aborted", Constants.WS_AT_ABORTED, 1, null);
}
- public void readOnlyOperation() throws IOException {
+ public void readOnlyOperation() throws AbstractKandulaException {
this.notify("ReadOnly", Constants.WS_AT_READONLY, 2, null);
}
- public void committedOperation() throws IOException {
+ public void committedOperation() throws AbstractKandulaException {
this.notify("Committed", Constants.WS_AT_COMMITTED, 3, null);
}
- public void replayOperation() throws IOException {
+ public void replayOperation() throws AbstractKandulaException {
//must send reply to epr
this.notify("Replay", Constants.WS_AT_REPLAY, 4, null);
}
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/ParticipantPortTypeRawXMLSkeleton.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/ParticipantPortTypeRawXMLSkeleton.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/ParticipantPortTypeRawXMLSkeleton.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/ParticipantPortTypeRawXMLSkeleton.java Sun Oct 2 05:26:06 2005
@@ -1,14 +1,7 @@
package org.apache.kandula.wsat.twopc;
-import java.io.IOException;
-
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.om.OMElement;
-import org.apache.kandula.Constants;
-import org.apache.kandula.context.AbstractContext;
-import org.apache.kandula.initiator.TransactionManager;
-import org.apache.kandula.storage.StorageFactory;
-import org.apache.kandula.context.coordination.CoordinationContext;
/*
* Copyright 2004,2005 The Apache Software Foundation.
@@ -39,8 +32,8 @@
this.msgContext = context;
}
- public OMElement prepareOperation(OMElement requestEle){
- return null;
+ public OMElement prepareOperation(OMElement requestEle) {
+ return null;
}
@@ -48,7 +41,7 @@
return null;
}
- public OMElement rollbackOperation(OMElement requestEle){
+ public OMElement rollbackOperation(OMElement requestEle) {
return null;
}
}
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/ParticipantPortTypeRawXMLStub.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/ParticipantPortTypeRawXMLStub.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/ParticipantPortTypeRawXMLStub.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/ParticipantPortTypeRawXMLStub.java Sun Oct 2 05:26:06 2005
@@ -1,9 +1,11 @@
package org.apache.kandula.wsat.twopc;
-import java.io.IOException;
-
+import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.deployment.DeploymentException;
import org.apache.kandula.Constants;
+import org.apache.kandula.faults.AbstractKandulaException;
+import org.apache.kandula.faults.KandulaGeneralException;
import org.apache.kandula.wsat.AbstractATNotifierStub;
public class ParticipantPortTypeRawXMLStub extends AbstractATNotifierStub {
@@ -42,32 +44,44 @@
/**
* Constructor
*/
- public ParticipantPortTypeRawXMLStub(String axis2Home,
- EndpointReference targetEndpoint) throws java.lang.Exception {
- this.toEPR = targetEndpoint;
+ public ParticipantPortTypeRawXMLStub(String axis2Home)
+ throws AbstractKandulaException {
+
//creating the configuration
- _configurationContext = new org.apache.axis2.context.ConfigurationContextFactory()
- .buildClientConfigurationContext(axis2Home);
- _configurationContext.getAxisConfiguration().addService(_service);
+ try {
+ _configurationContext = new org.apache.axis2.context.ConfigurationContextFactory()
+ .buildClientConfigurationContext(axis2Home);
+ _configurationContext.getAxisConfiguration().addService(_service);
+ } catch (DeploymentException e) {
+ throw new KandulaGeneralException(e);
+ } catch (AxisFault e1) {
+ throw new KandulaGeneralException(e1);
+ }
_serviceContext = _service.getParent().getServiceGroupContext(
_configurationContext).getServiceContext(
_service.getName().getLocalPart());
}
- public void prepareOperation() throws IOException {
+ public void prepareOperation(EndpointReference targetEndpoint)
+ throws AbstractKandulaException {
//TODO must send reply TO epr
+ this.toEPR = targetEndpoint;
this.notify("Prepare", Constants.WS_AT_PREPARE, 0, null);
}
- public void commitOperation() throws IOException {
+ public void commitOperation(EndpointReference targetEndpoint)
+ throws AbstractKandulaException {
//TODO must send reply to epr
+ this.toEPR = targetEndpoint;
this.notify("Commit", Constants.WS_AT_COMMIT, 1, null);
}
- public void rollbackOperation() throws IOException {
+ public void rollbackOperation(EndpointReference targetEndpoint)
+ throws AbstractKandulaException {
//TODO must send reply to epr
+ this.toEPR = targetEndpoint;
this.notify("Rollback", Constants.WS_AT_ROLLBACK, 2, null);
}
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/ParticipantServiceListener.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/ParticipantServiceListener.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/ParticipantServiceListener.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/twopc/ParticipantServiceListener.java Sun Oct 2 05:26:06 2005
@@ -23,12 +23,10 @@
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.description.ParameterImpl;
import org.apache.axis2.description.ServiceDescription;
-import org.apache.axis2.om.OMElement;
import org.apache.axis2.receivers.AbstractMessageReceiver;
import org.apache.axis2.receivers.RawXMLINOnlyMessageReceiver;
import org.apache.kandula.Constants;
import org.apache.kandula.utility.KandulaListener;
-import org.apache.kandula.wsat.completion.CompletionInitiatorPortTypeRawXMLSkeleton;
/**
* @author <a href="mailto:thilina@opensource.lk"> Thilina Gunarathne </a>
@@ -59,8 +57,7 @@
private EndpointReference setupListener() throws IOException {
QName serviceName = new QName("ParticipantPortType");
- String className = ParticipantPortTypeRawXMLSkeleton.class
- .getName();
+ String className = ParticipantPortTypeRawXMLSkeleton.class.getName();
ServiceDescription service = new ServiceDescription(serviceName);
service.addParameter(new ParameterImpl(
AbstractMessageReceiver.SERVICE_CLASS, className));
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationCoordinatorPortTypeRawXMLStub.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationCoordinatorPortTypeRawXMLStub.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationCoordinatorPortTypeRawXMLStub.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationCoordinatorPortTypeRawXMLStub.java Sun Oct 2 05:26:06 2005
@@ -16,6 +16,10 @@
*/
package org.apache.kandula.wscoor;
+import java.io.IOException;
+
+import javax.xml.namespace.QName;
+
import org.apache.axis2.addressing.AddressingConstants;
import org.apache.axis2.addressing.AnyContentType;
import org.apache.axis2.addressing.EndpointReference;
@@ -29,9 +33,6 @@
import org.apache.axis2.receivers.RawXMLINOnlyMessageReceiver;
import org.apache.kandula.Constants;
import org.apache.kandula.utility.KandulaListener;
-
-import javax.xml.namespace.QName;
-import java.io.IOException;
/**
* @author <a href="mailto:thilina@opensource.lk"> Thilina Gunarathne </a>
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeRawXMLAsyncMessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeRawXMLAsyncMessageReceiver.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeRawXMLAsyncMessageReceiver.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeRawXMLAsyncMessageReceiver.java Sun Oct 2 05:26:06 2005
@@ -29,16 +29,20 @@
public void invokeBusinessLogic(
org.apache.axis2.context.MessageContext msgContext,
- org.apache.axis2.context.MessageContext newMsgContext/*,
- ServerCallback callback*/) throws org.apache.axis2.AxisFault {
+ org.apache.axis2.context.MessageContext newMsgContext/*
+ * ,
+ * ServerCallback
+ * callback
+ */) throws org.apache.axis2.AxisFault {
try {
// get the implementation class for the Web Service
Object obj = getTheImplementationObject(msgContext);
-
+
//Inject the Message Context if it is asked for
- DependencyManager.configureBusinessLogicProvider(obj, msgContext, newMsgContext);
+ DependencyManager.configureBusinessLogicProvider(obj, msgContext,
+ newMsgContext);
ActivationPortTypeRawXMLSkeleton skel = (ActivationPortTypeRawXMLSkeleton) obj;
//Out Envelop
@@ -50,7 +54,7 @@
String methodName;
if (op.getName() != null
& (methodName = op.getName().getLocalPart()) != null) {
- if (methodName.equals("createCoordinationContextOperation")) {
+ if (("createCoordinationContextOperation").equals(methodName)) {
OMElement response = null;
//doc style
@@ -66,7 +70,8 @@
envelope.getBody().setFirstChild(response);
}
newMsgContext.setEnvelope(envelope);
- newMsgContext.setWSAAction(Constants.WS_COOR_CREATE_COORDINATIONCONTEXT_RESPONSE);
+ newMsgContext
+ .setWSAAction(Constants.WS_COOR_CREATE_COORDINATIONCONTEXT_RESPONSE);
}
} catch (Exception e) {
throw AxisFault.makeFault(e);
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeRawXMLSkeleton.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeRawXMLSkeleton.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeRawXMLSkeleton.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeRawXMLSkeleton.java Sun Oct 2 05:26:06 2005
@@ -54,7 +54,8 @@
SOAPFactory factory = OMAbstractFactory.getSOAP12Factory();
OMNamespace wsCoor = factory.createOMNamespace(Constants.WS_COOR,
"wscoor");
- OMElement responseEle = factory.createOMElement("CreateCoordinationContextResponse",wsCoor);
+ OMElement responseEle = factory.createOMElement(
+ "CreateCoordinationContextResponse", wsCoor);
responseEle.addChild(context.getCoordinationContext().toOM());
return responseEle;
} catch (AbstractKandulaException e) {
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationRequesterPortTypeRawXMLSkeleton.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationRequesterPortTypeRawXMLSkeleton.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationRequesterPortTypeRawXMLSkeleton.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationRequesterPortTypeRawXMLSkeleton.java Sun Oct 2 05:26:06 2005
@@ -3,9 +3,9 @@
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.om.OMElement;
import org.apache.kandula.context.AbstractContext;
+import org.apache.kandula.context.coordination.CoordinationContext;
import org.apache.kandula.initiator.TransactionManager;
import org.apache.kandula.storage.StorageFactory;
-import org.apache.kandula.context.coordination.CoordinationContext;
/*
* Copyright 2004,2005 The Apache Software Foundation.
@@ -36,12 +36,15 @@
this.msgContext = context;
}
- public OMElement createCoordinationContextResponseOperation(OMElement responseElement) {
+ public OMElement createCoordinationContextResponseOperation(
+ OMElement responseElement) {
OMElement response = responseElement.getFirstElement();
if ("CoordinationContext".equals(response.getLocalName())) {
msgContext.getMessageInformationHeaders().getReferenceParameters();
- CoordinationContext coordinationContext = CoordinationContext.Factory.newContext(response);
- AbstractContext context = (AbstractContext)StorageFactory.getInstance().getStore().get(TransactionManager.tempID);
+ CoordinationContext coordinationContext = CoordinationContext.Factory
+ .newContext(response);
+ AbstractContext context = (AbstractContext) StorageFactory
+ .getInstance().getStore().get(TransactionManager.tempID);
context.setCoordinationContext(coordinationContext);
}
return null;
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationCoordinatorPortTypeRawXMLStub.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationCoordinatorPortTypeRawXMLStub.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationCoordinatorPortTypeRawXMLStub.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationCoordinatorPortTypeRawXMLStub.java Sun Oct 2 05:26:06 2005
@@ -1,5 +1,9 @@
package org.apache.kandula.wscoor;
+import java.io.IOException;
+
+import javax.xml.namespace.QName;
+
import org.apache.axis2.addressing.AnyContentType;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.clientapi.MessageSender;
@@ -13,9 +17,6 @@
import org.apache.kandula.Constants;
import org.apache.kandula.utility.KandulaListener;
import org.apache.kandula.utility.KandulaUtils;
-
-import javax.xml.namespace.QName;
-import java.io.IOException;
public class RegistrationCoordinatorPortTypeRawXMLStub extends
org.apache.axis2.clientapi.Stub {
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeRawXMLAsyncMessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeRawXMLAsyncMessageReceiver.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeRawXMLAsyncMessageReceiver.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeRawXMLAsyncMessageReceiver.java Sun Oct 2 05:26:06 2005
@@ -29,8 +29,11 @@
public void invokeBusinessLogic(
org.apache.axis2.context.MessageContext msgContext,
- org.apache.axis2.context.MessageContext newMsgContext/*,
- ServerCallback callback*/) throws org.apache.axis2.AxisFault {
+ org.apache.axis2.context.MessageContext newMsgContext/*
+ * ,
+ * ServerCallback
+ * callback
+ */) throws org.apache.axis2.AxisFault {
try {
@@ -38,7 +41,8 @@
Object obj = getTheImplementationObject(msgContext);
//Inject the Message Context if it is asked for
- DependencyManager.configureBusinessLogicProvider(obj, msgContext, newMsgContext);
+ DependencyManager.configureBusinessLogicProvider(obj, msgContext,
+ newMsgContext);
RegistrationPortTypeRawXMLSkeleton skel = (RegistrationPortTypeRawXMLSkeleton) obj;
//Out Envelop
@@ -50,7 +54,7 @@
String methodName;
if (op.getName() != null
& (methodName = op.getName().getLocalPart()) != null) {
- if (methodName.equals("registerOperation")) {
+ if (("registerOperation").equals(methodName)) {
OMElement response = null;
//doc style
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeRawXMLSkeleton.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeRawXMLSkeleton.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeRawXMLSkeleton.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeRawXMLSkeleton.java Sun Oct 2 05:26:06 2005
@@ -17,12 +17,10 @@
package org.apache.kandula.wscoor;
import java.util.ArrayList;
-import java.util.Iterator;
import javax.xml.namespace.QName;
import org.apache.axis2.AxisFault;
-import org.apache.axis2.addressing.AnyContentType;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.om.OMAbstractFactory;
@@ -45,42 +43,43 @@
this.msgContext = msgContext;
}
- public OMElement registerOperation(OMElement request)
- throws AxisFault {
+ public OMElement registerOperation(OMElement request) throws AxisFault {
String protocolIdentifier;
EndpointReference participantEPR;
String activityId;
/*
- * Extracting data from the received message
+ * Extracting data from the received message
*/
protocolIdentifier = request.getFirstChildWithName(
new QName("ProtocolIdentifier")).getText();
OMElement participantEPRElement = request
.getFirstChildWithName(new QName("ParticipantProtocolService"));
- //Extracting the participant EPR
+ //Extracting the participant EPR
participantEPR = KandulaUtils.endpointFromOM(participantEPRElement);
//have to extract the reference parameter "id". Axis2 does not support
ArrayList list = msgContext.getMessageInformationHeaders()
.getReferenceParameters();
- //TODO :Have to use the Activity ID came with EPR as a reference property
+ //TODO :Have to use the Activity ID came with EPR as a reference
+ // property
activityId = Coordinator.ACTIVITY_ID;
/*
* Registering the participant for the activity for the given protocol
*/
- try{
- Coordinator coordinator = new Coordinator();
- EndpointReference epr = coordinator.registerParticipant(activityId,
- protocolIdentifier, participantEPR);
- SOAPFactory factory = OMAbstractFactory.getSOAP12Factory();
- OMNamespace wsCoor = factory.createOMNamespace(Constants.WS_COOR,
- "wscoor");
- OMElement responseEle = factory.createOMElement("RegisterResponse",wsCoor);
- responseEle.addChild(toOM(epr));
- return responseEle;
+ try {
+ Coordinator coordinator = new Coordinator();
+ EndpointReference epr = coordinator.registerParticipant(activityId,
+ protocolIdentifier, participantEPR);
+ SOAPFactory factory = OMAbstractFactory.getSOAP12Factory();
+ OMNamespace wsCoor = factory.createOMNamespace(Constants.WS_COOR,
+ "wscoor");
+ OMElement responseEle = factory.createOMElement("RegisterResponse",
+ wsCoor);
+ responseEle.addChild(toOM(epr));
+ return responseEle;
} catch (AbstractKandulaException e) {
AxisFault fault = new AxisFault(e);
fault.setFaultCode(e.getFaultCode());
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=293101&r1=293100&r2=293101&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 Oct 2 05:26:06 2005
@@ -5,7 +5,6 @@
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;
@@ -42,9 +41,12 @@
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);
+ EndpointReference coordinatorService = KandulaUtils
+ .endpointFromOM(response.getFirstElement());
+ AbstractContext context = (AbstractContext) StorageFactory
+ .getInstance().getStore().get(TransactionManager.tempID);
+ context.setProperty(ATActivityContext.COORDINATION_EPR,
+ coordinatorService);
}
return null;
}
Modified: webservices/kandula/trunk/java/test/org/apache/kandula/context/ActivityContextTest.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/test/org/apache/kandula/context/ActivityContextTest.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/test/org/apache/kandula/context/ActivityContextTest.java (original)
+++ webservices/kandula/trunk/java/test/org/apache/kandula/context/ActivityContextTest.java Sun Oct 2 05:26:06 2005
@@ -47,4 +47,4 @@
//TODO Implement unlock().
}
-}
+}
\ No newline at end of file
Modified: webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/CoordinatorImplTest.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/CoordinatorImplTest.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/CoordinatorImplTest.java (original)
+++ webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/CoordinatorImplTest.java Sun Oct 2 05:26:06 2005
@@ -46,34 +46,44 @@
}
/*
- * Class under test for ActivityContext createCoordinationContext(String, long)
+ * Class under test for ActivityContext createCoordinationContext(String,
+ * long)
*/
- public void testCreateCoordinationContextStringlong() throws AbstractKandulaException {
+ public void testCreateCoordinationContextStringlong()
+ throws AbstractKandulaException {
Coordinator coordinator = new Coordinator();
- AbstractContext context = coordinator.createCoordinationContext(Constants.WS_AT, 3000);
+ AbstractContext context = coordinator.createCoordinationContext(
+ Constants.WS_AT, 3000);
assertTrue(ATActivityContext.class.isInstance(context));
assertNotNull(context.getCoordinationContext());
assertTrue(context.getStatus() == Status.CoordinatorStatus.STATUS_ACTIVE);
}
/*
- * Class under test for ActivityContext createCoordinationContext(CoordinationContext)
+ * Class under test for ActivityContext
+ * createCoordinationContext(CoordinationContext)
*/
- public void testCreateCoordinationContextCoordinationContext() throws AbstractKandulaException {
+ public void testCreateCoordinationContextCoordinationContext()
+ throws AbstractKandulaException {
Coordinator coordinator = new Coordinator();
- CoordinationContext coorContext = CoordinationContext.Factory.newContext("uuid:29919219jdk02102021",Constants.WS_AT,new EndpointReference(""));
+ CoordinationContext coorContext = CoordinationContext.Factory
+ .newContext("uuid:29919219jdk02102021", Constants.WS_AT,
+ new EndpointReference(""));
coorContext.setExpires(3000);
// coorContext.setRegistrationService()
- AbstractContext context = coordinator.createCoordinationContext(coorContext);
+ AbstractContext context = coordinator
+ .createCoordinationContext(coorContext);
assertTrue(ATActivityContext.class.isInstance(context));
assertNotNull(context.getCoordinationContext());
assertTrue(context.getStatus() == Status.CoordinatorStatus.STATUS_ACTIVE);
- assertEquals(context.getCoordinationContext().getCoordinationType(), coorContext.getCoordinationType());
- assertEquals(context.getCoordinationContext().getActivityID(), coorContext.getActivityID());
+ assertEquals(context.getCoordinationContext().getCoordinationType(),
+ coorContext.getCoordinationType());
+ assertEquals(context.getCoordinationContext().getActivityID(),
+ coorContext.getActivityID());
}
public void testRegisterParticipant() {
//TODO Implement registerParticipant().
}
-}
+}
\ No newline at end of file
Modified: webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/at/ATCoordinatorTest.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/at/ATCoordinatorTest.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/at/ATCoordinatorTest.java (original)
+++ webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/at/ATCoordinatorTest.java Sun Oct 2 05:26:06 2005
@@ -32,7 +32,7 @@
/**
* Constructor for ATCoordinatorTest.
- *
+ *
* @param arg0
*/
public ATCoordinatorTest(String arg0) {
@@ -47,4 +47,4 @@
//TODO Implement rollbackOperation().
}
-}
+}
\ No newline at end of file
Modified: webservices/kandula/trunk/java/test/org/apache/kandula/integration/CreateCoordinationContextTest.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/test/org/apache/kandula/integration/CreateCoordinationContextTest.java?rev=293101&r1=293100&r2=293101&view=diff
==============================================================================
--- webservices/kandula/trunk/java/test/org/apache/kandula/integration/CreateCoordinationContextTest.java (original)
+++ webservices/kandula/trunk/java/test/org/apache/kandula/integration/CreateCoordinationContextTest.java Sun Oct 2 05:26:06 2005
@@ -20,7 +20,10 @@
* @author <a href="mailto:thilina@opensource.lk">Thilina Gunarathne </a>
*/
+import java.io.File;
+
import junit.framework.TestCase;
+
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.context.ConfigurationContext;
@@ -29,8 +32,6 @@
import org.apache.kandula.Constants;
import org.apache.kandula.initiator.TransactionManager;
-import java.io.File;
-
public class CreateCoordinationContextTest extends TestCase {
private String repository = "test-resources/testing-repository";
@@ -39,7 +40,6 @@
private boolean finish = false;
-
public CreateCoordinationContextTest() {
super(CreateCoordinationContextTest.class.getName());
}
@@ -52,20 +52,17 @@
ConfigurationContextFactory erfac = new ConfigurationContextFactory();
File file = new File(repository);
if (!file.exists()) {
- throw new Exception(
- "repository directory " + file.getAbsolutePath() +
- " does not exists");
+ throw new Exception("repository directory "
+ + file.getAbsolutePath() + " does not exists");
}
- ConfigurationContext er = erfac.buildConfigurationContext(
- file.getAbsolutePath());
+ ConfigurationContext er = erfac.buildConfigurationContext(file
+ .getAbsolutePath());
server = new SimpleHTTPServer(er, 8081);
try {
server.start();
- System.out.print(
- "Server started on port " + 8081 +
- ".....");
+ System.out.print("Server started on port " + 8081 + ".....");
} finally {
}
@@ -76,17 +73,18 @@
throw new AxisFault("Thread interuptted", e1);
}
-
}
protected void tearDown() throws Exception {
server.stop();
}
-
public void testEchoXMLSync() throws Exception {
- TransactionManager tm = new TransactionManager(Constants.WS_AT, new EndpointReference("http://localhost:8081/axis/services/ActivationCoordinator"));
- //Thread.sleep(100000);
+ TransactionManager tm = new TransactionManager(
+ Constants.WS_AT,
+ new EndpointReference(
+ "http://localhost:8081/axis/services/ActivationCoordinator"));
+
tm.begin();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: kandula-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: kandula-dev-help@ws.apache.org