Added: webservices/kandula/trunk/java/src/org/apache/kandula/utility/EndpointReferenceFactory.java URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/utility/EndpointReferenceFactory.java?rev=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/src/org/apache/kandula/utility/EndpointReferenceFactory.java (added) +++ webservices/kandula/trunk/java/src/org/apache/kandula/utility/EndpointReferenceFactory.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,89 @@ +/*
+ * Copyright 2004 The Apache Software Foundation. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ +package org.apache.kandula.utility; + +import java.io.InputStream; +import java.net.InetAddress; +import java.util.Properties; + +import org.apache.axis2.addressing.EndpointReference; +import org.apache.kandula.typemapping.EndPointReference; +import org.apache.xmlbeans.SchemaType; +import org.apache.xmlbeans.impl.schema.SchemaTypeImpl; +import org.xmlsoap.schemas.ws.x2002.x07.utility.impl.PortReferenceTypeImpl; +import org.xmlsoap.schemas.ws.x2004.x03.addressing.ReferencePropertiesType; +import org.xmlsoap.schemas.ws.x2004.x03.addressing.impl.EndpointReferenceTypeImpl; + +public class EndpointReferenceFactory { + static final String PROPERTY_FILE= "endpoints.conf"; + static final String PROTOCOL_PROPERTY= "protocol"; + static final String HOST_PROPERTY= "host"; + static final String PORT_PROPERTY= "port"; + static EndpointReferenceFactory instance= null; + Properties properties= null; + String location= null; + + private EndpointReferenceFactory() { + InputStream in= getClass().getClassLoader().getResourceAsStream(PROPERTY_FILE); + properties= new Properties(); + try { + properties.load(in); + in.close(); + String host= properties.getProperty(HOST_PROPERTY); + if (host == null) + host= InetAddress.getLocalHost().getHostAddress(); + location= + properties.getProperty(PROTOCOL_PROPERTY) + + "://" + + host + + ":" + + properties.getProperty(PORT_PROPERTY); + } + catch (Exception e) { + if (e instanceof RuntimeException) + throw (RuntimeException)e; + else + throw new RuntimeException(e); + } + } + + public static EndpointReferenceFactory getInstance() { + if (instance == null) + instance= new EndpointReferenceFactory(); + return instance; + } + + public EndPointReference getRegistrationEndpoint() + { + //TODO set this somehow reading the conf file + return EndPointReference.Factory.newInstance(); + } +// public EndpointReferenceTypeImpl getEndpointReference(PortReferenceTypeImpl portType, ReferencePropertiesType referenceProperties) { +// try { +// EndpointReferenceTypeImpl endpointReference = new EndpointReferenceTypeImpl(SchemaTypeImpl.); +// endpointReference.setPortTypesetPortType(portType); +// endpointReference.setProperties(referenceProperties); +// return endpointReference; +// } +// catch (Exception e) { +// if (e instanceof RuntimeException) +// throw (RuntimeException)e; +// else +// throw new RuntimeException(e); +// } +// } +} Added: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CompletionPortTypeRPCMessageReceiver.java URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CompletionPortTypeRPCMessageReceiver.java?rev=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CompletionPortTypeRPCMessageReceiver.java (added) +++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CompletionPortTypeRPCMessageReceiver.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,87 @@ + + + package org.apache.kandula.wsat; + + /** + * Auto generated message receiver + */ + + public class CompletionPortTypeRPCMessageReceiver extends org.apache.axis2.receivers.AbstractInOutSyncMessageReceiver{ + + public void invokeBusinessLogic(org.apache.axis2.context.MessageContext msgContext, org.apache.axis2.context.MessageContext newMsgContext) + throws org.apache.axis2.AxisFault{ + + try { + + // get the implementation class for the Web Service + Object obj = getTheImplementationObject(msgContext); + + CompletionPortTypeRPCSkeleton skel = (CompletionPortTypeRPCSkeleton)obj; + //Out Envelop + org.apache.axis2.soap.SOAPEnvelope envelope = null; + //Find the operation that has been set by the Dispatch phase. + org.apache.axis2.description.OperationDescription op = msgContext.getOperationContext().getAxisOperation(); + if (op == null) { + throw new org.apache.axis2.AxisFault("Operation is not located, if this is doclit style the SOAP-ACTION should specified via the SOAP Action to use the RawXMLProvider"); + } + + String methodName; + if(op.getName() != null & (methodName = op.getName().getLocalPart()) != null){ + + + + + if(methodName.equals("CommitOperation")){ + + + org.xmlsoap.schemas.ws.x2003.x09.wsat.CommittedDocument param217 = null; + + //doc style + param217 = skel.CommitOperation((org.xmlsoap.schemas.ws.x2003.x09.wsat.CommitDocument)codegen.databinding.CommitOperationDatabindingSupporter.fromOM((org.apache.axis2.om.OMElement)msgContext.getEnvelope().getBody().getFirstChild().detach(), org.xmlsoap.schemas.ws.x2003.x09.wsat.CommitDocument.class)); + + //Create a default envelop + envelope = getSOAPFactory().getDefaultEnvelope(); + //Create a Omelement of the result if a result exist + + envelope.getBody().setFirstChild(codegen.databinding.CommitOperationDatabindingSupporter.toOM(param217)); + + + + + } + + + + if(methodName.equals("RollbackOperation")){ + + + org.xmlsoap.schemas.ws.x2003.x09.wsat.AbortedDocument param219 = null; + + //doc style + param219 = skel.RollbackOperation((org.xmlsoap.schemas.ws.x2003.x09.wsat.RollbackDocument)codegen.databinding.RollbackOperationDatabindingSupporter.fromOM((org.apache.axis2.om.OMElement)msgContext.getEnvelope().getBody().getFirstChild().detach(), org.xmlsoap.schemas.ws.x2003.x09.wsat.RollbackDocument.class)); + + //Create a default envelop + envelope = getSOAPFactory().getDefaultEnvelope(); + //Create a Omelement of the result if a result exist + + envelope.getBody().setFirstChild(codegen.databinding.RollbackOperationDatabindingSupporter.toOM(param219)); + + + + + } + + + newMsgContext.setEnvelope(envelope); + } + + + + } catch (Exception e) { + throw org.apache.axis2.AxisFault.makeFault(e); + } + + } + + } + \ No newline at end of file Added: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CompletionPortTypeRPCSkeleton.java URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CompletionPortTypeRPCSkeleton.java?rev=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CompletionPortTypeRPCSkeleton.java (added) +++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CompletionPortTypeRPCSkeleton.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,36 @@ + + + package org.apache.kandula.wsat; + + /** + * Auto generated java skeleton for the service by the Axis code generator + */ + + public class CompletionPortTypeRPCSkeleton { + + + /** + * Auto generated method signature + [EMAIL PROTECTED] param200 + */ + public org.xmlsoap.schemas.ws.x2003.x09.wsat.CommittedDocument CommitOperation(org.xmlsoap.schemas.ws.x2003.x09.wsat.CommitDocument param200){ + //Todo fill this with the necessary business logic + return null; + } + + + + + /** + * Auto generated method signature + [EMAIL PROTECTED] param202 + */ + public org.xmlsoap.schemas.ws.x2003.x09.wsat.AbortedDocument RollbackOperation(org.xmlsoap.schemas.ws.x2003.x09.wsat.RollbackDocument param202){ + //Todo fill this with the necessary business logic + return null; + } + + + + } + \ No newline at end of file Added: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CoordinatorPortTypeRPCMessageReceiver.java URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CoordinatorPortTypeRPCMessageReceiver.java?rev=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CoordinatorPortTypeRPCMessageReceiver.java (added) +++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CoordinatorPortTypeRPCMessageReceiver.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,104 @@ + + + package org.apache.kandula.wsat; + + /** + * Auto generated message receiver + */ + + public class CoordinatorPortTypeRPCMessageReceiver extends org.apache.axis2.receivers.AbstractInOutSyncMessageReceiver{ + + public void invokeBusinessLogic(org.apache.axis2.context.MessageContext msgContext, org.apache.axis2.context.MessageContext newMsgContext) + throws org.apache.axis2.AxisFault{ + + try { + + // get the implementation class for the Web Service + Object obj = getTheImplementationObject(msgContext); + + CoordinatorPortTypeRPCSkeleton skel = (CoordinatorPortTypeRPCSkeleton)obj; + //Out Envelop + org.apache.axis2.soap.SOAPEnvelope envelope = null; + //Find the operation that has been set by the Dispatch phase. + org.apache.axis2.description.OperationDescription op = msgContext.getOperationContext().getAxisOperation(); + if (op == null) { + throw new org.apache.axis2.AxisFault("Operation is not located, if this is doclit style the SOAP-ACTION should specified via the SOAP Action to use the RawXMLProvider"); + } + + String methodName; + if(op.getName() != null & (methodName = op.getName().getLocalPart()) != null){ + + + + + if(methodName.equals("ReplayOperation")){ + + + org.xmlsoap.schemas.ws.x2003.x09.wsat.ReplayResponseDocument param175 = null; + + //doc style + param175 = skel.ReplayOperation((org.xmlsoap.schemas.ws.x2003.x09.wsat.ReplayDocument)codegen.databinding.ReplayOperationDatabindingSupporter.fromOM((org.apache.axis2.om.OMElement)msgContext.getEnvelope().getBody().getFirstChild().detach(), org.xmlsoap.schemas.ws.x2003.x09.wsat.ReplayDocument.class)); + + //Create a default envelop + envelope = getSOAPFactory().getDefaultEnvelope(); + //Create a Omelement of the result if a result exist + + envelope.getBody().setFirstChild(codegen.databinding.ReplayOperationDatabindingSupporter.toOM(param175)); + + + + + } + + + + if(methodName.equals("AbortedOperation")){ + + + + //doc style + skel.AbortedOperation((org.xmlsoap.schemas.ws.x2003.x09.wsat.AbortedDocument)codegen.databinding.AbortedOperationDatabindingSupporter.fromOM((org.apache.axis2.om.OMElement)msgContext.getEnvelope().getBody().getFirstChild().detach(), org.xmlsoap.schemas.ws.x2003.x09.wsat.AbortedDocument.class)); + + //Create a default envelop + envelope = getSOAPFactory().getDefaultEnvelope(); + //Create a Omelement of the result if a result exist + + + + + + } + + + + if(methodName.equals("ReadOnlyOperation")){ + + + + //doc style + skel.ReadOnlyOperation((org.xmlsoap.schemas.ws.x2003.x09.wsat.ReadOnlyDocument)codegen.databinding.ReadOnlyOperationDatabindingSupporter.fromOM((org.apache.axis2.om.OMElement)msgContext.getEnvelope().getBody().getFirstChild().detach(), org.xmlsoap.schemas.ws.x2003.x09.wsat.ReadOnlyDocument.class)); + + //Create a default envelop + envelope = getSOAPFactory().getDefaultEnvelope(); + //Create a Omelement of the result if a result exist + + + + + + } + + + newMsgContext.setEnvelope(envelope); + } + + + + } catch (Exception e) { + throw org.apache.axis2.AxisFault.makeFault(e); + } + + } + + } + \ No newline at end of file Added: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CoordinatorPortTypeRPCSkeleton.java URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CoordinatorPortTypeRPCSkeleton.java?rev=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CoordinatorPortTypeRPCSkeleton.java (added) +++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/CoordinatorPortTypeRPCSkeleton.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,48 @@ + + + package org.apache.kandula.wsat; + + /** + * Auto generated java skeleton for the service by the Axis code generator + */ + + public class CoordinatorPortTypeRPCSkeleton { + + + /** + * Auto generated method signature + [EMAIL PROTECTED] param150 + */ + public org.xmlsoap.schemas.ws.x2003.x09.wsat.ReplayResponseDocument ReplayOperation(org.xmlsoap.schemas.ws.x2003.x09.wsat.ReplayDocument param150){ + //Todo fill this with the necessary business logic + return null; + } + + + + + /** + * Auto generated method signature + [EMAIL PROTECTED] param152 + */ + public void AbortedOperation(org.xmlsoap.schemas.ws.x2003.x09.wsat.AbortedDocument param152){ + //Todo fill this with the necessary business logic + + } + + + + + /** + * Auto generated method signature + [EMAIL PROTECTED] param154 + */ + public void ReadOnlyOperation(org.xmlsoap.schemas.ws.x2003.x09.wsat.ReadOnlyDocument param154){ + //Todo fill this with the necessary business logic + + } + + + + } + \ No newline at end of file Added: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/ParticipantPortTypeRPCMessageReceiver.java URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/ParticipantPortTypeRPCMessageReceiver.java?rev=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/ParticipantPortTypeRPCMessageReceiver.java (added) +++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/ParticipantPortTypeRPCMessageReceiver.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,108 @@ + + + package org.apache.kandula.wsat; + + /** + * Auto generated message receiver + */ + + public class ParticipantPortTypeRPCMessageReceiver extends org.apache.axis2.receivers.AbstractInOutSyncMessageReceiver{ + + public void invokeBusinessLogic(org.apache.axis2.context.MessageContext msgContext, org.apache.axis2.context.MessageContext newMsgContext) + throws org.apache.axis2.AxisFault{ + + try { + + // get the implementation class for the Web Service + Object obj = getTheImplementationObject(msgContext); + + ParticipantPortTypeRPCSkeleton skel = (ParticipantPortTypeRPCSkeleton)obj; + //Out Envelop + org.apache.axis2.soap.SOAPEnvelope envelope = null; + //Find the operation that has been set by the Dispatch phase. + org.apache.axis2.description.OperationDescription op = msgContext.getOperationContext().getAxisOperation(); + if (op == null) { + throw new org.apache.axis2.AxisFault("Operation is not located, if this is doclit style the SOAP-ACTION should specified via the SOAP Action to use the RawXMLProvider"); + } + + String methodName; + if(op.getName() != null & (methodName = op.getName().getLocalPart()) != null){ + + + + + if(methodName.equals("CommitOperation")){ + + + org.xmlsoap.schemas.ws.x2003.x09.wsat.CommittedDocument param45 = null; + + //doc style + param45 = skel.CommitOperation((org.xmlsoap.schemas.ws.x2003.x09.wsat.CommitDocument)codegen.databinding.CommitOperationDatabindingSupporter.fromOM((org.apache.axis2.om.OMElement)msgContext.getEnvelope().getBody().getFirstChild().detach(), org.xmlsoap.schemas.ws.x2003.x09.wsat.CommitDocument.class)); + + //Create a default envelop + envelope = getSOAPFactory().getDefaultEnvelope(); + //Create a Omelement of the result if a result exist + + envelope.getBody().setFirstChild(codegen.databinding.CommitOperationDatabindingSupporter.toOM(param45)); + + + + + } + + + + if(methodName.equals("RollbackOperation")){ + + + org.xmlsoap.schemas.ws.x2003.x09.wsat.AbortedDocument param47 = null; + + //doc style + param47 = skel.RollbackOperation((org.xmlsoap.schemas.ws.x2003.x09.wsat.RollbackDocument)codegen.databinding.RollbackOperationDatabindingSupporter.fromOM((org.apache.axis2.om.OMElement)msgContext.getEnvelope().getBody().getFirstChild().detach(), org.xmlsoap.schemas.ws.x2003.x09.wsat.RollbackDocument.class)); + + //Create a default envelop + envelope = getSOAPFactory().getDefaultEnvelope(); + //Create a Omelement of the result if a result exist + + envelope.getBody().setFirstChild(codegen.databinding.RollbackOperationDatabindingSupporter.toOM(param47)); + + + + + } + + + + if(methodName.equals("PrepareOperation")){ + + + org.xmlsoap.schemas.ws.x2003.x09.wsat.PrepareResponseDocument param49 = null; + + //doc style + param49 = skel.PrepareOperation((org.xmlsoap.schemas.ws.x2003.x09.wsat.PrepareDocument)codegen.databinding.PrepareOperationDatabindingSupporter.fromOM((org.apache.axis2.om.OMElement)msgContext.getEnvelope().getBody().getFirstChild().detach(), org.xmlsoap.schemas.ws.x2003.x09.wsat.PrepareDocument.class)); + + //Create a default envelop + envelope = getSOAPFactory().getDefaultEnvelope(); + //Create a Omelement of the result if a result exist + + envelope.getBody().setFirstChild(codegen.databinding.PrepareOperationDatabindingSupporter.toOM(param49)); + + + + + } + + + newMsgContext.setEnvelope(envelope); + } + + + + } catch (Exception e) { + throw org.apache.axis2.AxisFault.makeFault(e); + } + + } + + } + \ No newline at end of file Added: webservices/kandula/trunk/java/src/org/apache/kandula/wsat/ParticipantPortTypeRPCSkeleton.java URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wsat/ParticipantPortTypeRPCSkeleton.java?rev=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/src/org/apache/kandula/wsat/ParticipantPortTypeRPCSkeleton.java (added) +++ webservices/kandula/trunk/java/src/org/apache/kandula/wsat/ParticipantPortTypeRPCSkeleton.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,48 @@ + + + package org.apache.kandula.wsat; + + /** + * Auto generated java skeleton for the service by the Axis code generator + */ + + public class ParticipantPortTypeRPCSkeleton { + + + /** + * Auto generated method signature + [EMAIL PROTECTED] param20 + */ + public org.xmlsoap.schemas.ws.x2003.x09.wsat.CommittedDocument CommitOperation(org.xmlsoap.schemas.ws.x2003.x09.wsat.CommitDocument param20){ + //Todo fill this with the necessary business logic + return null; + } + + + + + /** + * Auto generated method signature + [EMAIL PROTECTED] param22 + */ + public org.xmlsoap.schemas.ws.x2003.x09.wsat.AbortedDocument RollbackOperation(org.xmlsoap.schemas.ws.x2003.x09.wsat.RollbackDocument param22){ + //Todo fill this with the necessary business logic + return null; + } + + + + + /** + * Auto generated method signature + [EMAIL PROTECTED] param24 + */ + public org.xmlsoap.schemas.ws.x2003.x09.wsat.PrepareResponseDocument PrepareOperation(org.xmlsoap.schemas.ws.x2003.x09.wsat.PrepareDocument param24){ + //Todo fill this with the necessary business logic + return null; + } + + + + } + \ No newline at end of file Added: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeMessageReceiver.java URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeMessageReceiver.java?rev=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeMessageReceiver.java (added) +++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeMessageReceiver.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,66 @@ + + + package org.apache.kandula.wscoor; + + /** + * Auto generated message receiver + */ + + public class ActivationPortTypeMessageReceiver extends org.apache.axis2.receivers.AbstractInOutSyncMessageReceiver{ + + public void invokeBusinessLogic(org.apache.axis2.context.MessageContext msgContext, org.apache.axis2.context.MessageContext newMsgContext) + throws org.apache.axis2.AxisFault{ + + try { + + // get the implementation class for the Web Service + Object obj = getTheImplementationObject(msgContext); + + ActivationPortTypeSkeleton skel = (ActivationPortTypeSkeleton)obj; + //Out Envelop + org.apache.axis2.soap.SOAPEnvelope envelope = null; + //Find the operation that has been set by the Dispatch phase. + org.apache.axis2.description.OperationDescription op = msgContext.getOperationContext().getAxisOperation(); + if (op == null) { + throw new org.apache.axis2.AxisFault("Operation is not located, if this is doclit style the SOAP-ACTION should specified via the SOAP Action to use the RawXMLProvider"); + } + + String methodName; + if(op.getName() != null & (methodName = op.getName().getLocalPart()) != null){ + + + + + if(methodName.equals("CreateCoordinationContextOperation")){ + + + org.xmlsoap.schemas.ws.x2003.x09.wscoor.CreateCoordinationContextResponseDocument param19 = null; + + //doc style + param19 = skel.CreateCoordinationContextOperation((org.xmlsoap.schemas.ws.x2003.x09.wscoor.CreateCoordinationContextDocument)codegen.databinding.CreateCoordinationContextOperationDatabindingSupporter.fromOM((org.apache.axis2.om.OMElement)msgContext.getEnvelope().getBody().getFirstChild().detach(), org.xmlsoap.schemas.ws.x2003.x09.wscoor.CreateCoordinationContextDocument.class)); + + //Create a default envelop + envelope = getSOAPFactory().getDefaultEnvelope(); + //Create a Omelement of the result if a result exist + + envelope.getBody().setFirstChild(codegen.databinding.CreateCoordinationContextOperationDatabindingSupporter.toOM(param19)); + + + + + } + + + newMsgContext.setEnvelope(envelope); + } + + + + } catch (Exception e) { + throw org.apache.axis2.AxisFault.makeFault(e); + } + + } + + } + \ No newline at end of file Added: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeSkeleton.java URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeSkeleton.java?rev=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeSkeleton.java (added) +++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationPortTypeSkeleton.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,49 @@ +package org.apache.kandula.wscoor; + +import org.apache.kandula.KandulaException; +import org.apache.kandula.coordinator.Coordinator; +import org.apache.kandula.coordinator.CoordinatorImpl; +import org.apache.kandula.coordinator.context.ActivityContext; +import org.apache.kandula.typemapping.CoordinationContext; +import org.xmlsoap.schemas.ws.x2003.x09.wscoor.CoordinationContextType; +import org.xmlsoap.schemas.ws.x2003.x09.wscoor.CreateCoordinationContextResponseDocument; +import org.xmlsoap.schemas.ws.x2003.x09.wscoor.CreateCoordinationContextResponseType; + +/** + * Auto generated java skeleton for the service by the Axis code generator + */ + +public class ActivationPortTypeSkeleton { + + /** + * Auto generated method signature + [EMAIL PROTECTED] requestDoc + * @throws KandulaException + */ + public org.xmlsoap.schemas.ws.x2003.x09.wscoor.CreateCoordinationContextResponseDocument CreateCoordinationContextOperation( + org.xmlsoap.schemas.ws.x2003.x09.wscoor.CreateCoordinationContextDocument requestDoc) + throws KandulaException { + ActivityContext context; + Coordinator coordinator = new CoordinatorImpl(); + if (requestDoc.getCreateCoordinationContext().getCurrentContext() != null) { + CoordinationContext coorContext = CoordinationContext.Factory.newInstance(requestDoc + .getCreateCoordinationContext().getCurrentContext()); + context = coordinator.createCoordinationContext(coorContext); + }else + { + context = coordinator.createCoordinationContext(requestDoc + .getCreateCoordinationContext().getCoordinationType(), Long + .parseLong(requestDoc.getCreateCoordinationContext() + .getExpires().getId())); + } + CreateCoordinationContextResponseDocument responseDoc = CreateCoordinationContextResponseDocument.Factory + .newInstance(); + CreateCoordinationContextResponseType responseType = CreateCoordinationContextResponseType.Factory + .newInstance(); + responseType.setCoordinationContext((CoordinationContextType)context.getCoordinationContext().getCoordinationContextType()); + responseDoc.setCreateCoordinationContextResponse(responseType); + return responseDoc; + + } + +} \ No newline at end of file Added: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeMessageReceiver.java URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeMessageReceiver.java?rev=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeMessageReceiver.java (added) +++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeMessageReceiver.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,66 @@ + + + package org.apache.kandula.wscoor; + + /** + * Auto generated message receiver + */ + + public class RegistrationPortTypeMessageReceiver extends org.apache.axis2.receivers.AbstractInOutSyncMessageReceiver{ + + public void invokeBusinessLogic(org.apache.axis2.context.MessageContext msgContext, org.apache.axis2.context.MessageContext newMsgContext) + throws org.apache.axis2.AxisFault{ + + try { + + // get the implementation class for the Web Service + Object obj = getTheImplementationObject(msgContext); + + RegistrationPortTypeSkeleton skel = (RegistrationPortTypeSkeleton)obj; + //Out Envelop + org.apache.axis2.soap.SOAPEnvelope envelope = null; + //Find the operation that has been set by the Dispatch phase. + org.apache.axis2.description.OperationDescription op = msgContext.getOperationContext().getAxisOperation(); + if (op == null) { + throw new org.apache.axis2.AxisFault("Operation is not located, if this is doclit style the SOAP-ACTION should specified via the SOAP Action to use the RawXMLProvider"); + } + + String methodName; + if(op.getName() != null & (methodName = op.getName().getLocalPart()) != null){ + + + + + if(methodName.equals("RegisterOperation")){ + + + org.xmlsoap.schemas.ws.x2003.x09.wscoor.RegisterResponseDocument param49 = null; + + //doc style + param49 = skel.RegisterOperation((org.xmlsoap.schemas.ws.x2003.x09.wscoor.RegisterDocument)codegen.databinding.RegisterOperationDatabindingSupporter.fromOM((org.apache.axis2.om.OMElement)msgContext.getEnvelope().getBody().getFirstChild().detach(), org.xmlsoap.schemas.ws.x2003.x09.wscoor.RegisterDocument.class)); + + //Create a default envelop + envelope = getSOAPFactory().getDefaultEnvelope(); + //Create a Omelement of the result if a result exist + + envelope.getBody().setFirstChild(codegen.databinding.RegisterOperationDatabindingSupporter.toOM(param49)); + + + + + } + + + newMsgContext.setEnvelope(envelope); + } + + + + } catch (Exception e) { + throw org.apache.axis2.AxisFault.makeFault(e); + } + + } + + } + \ No newline at end of file Added: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeSkeleton.java URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeSkeleton.java?rev=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeSkeleton.java (added) +++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationPortTypeSkeleton.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,21 @@ + + + package org.apache.kandula.wscoor; + + /** + * Auto generated java skeleton for the service by the Axis code generator + */ + + public class RegistrationPortTypeSkeleton { + + + /** + * Auto generated method signature + [EMAIL PROTECTED] param40 + */ + public org.xmlsoap.schemas.ws.x2003.x09.wscoor.RegisterResponseDocument RegisterOperation(org.xmlsoap.schemas.ws.x2003.x09.wscoor.RegisterDocument param40){ + //Todo fill this with the necessary business logic + return null; + } + } + \ No newline at end of file Added: 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=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/CoordinatorImplTest.java (added) +++ webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/CoordinatorImplTest.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,81 @@ +/* + * Copyright 2004 The Apache Software Foundation. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ +package org.apache.kandula.coordinator; + +import org.apache.kandula.Constants; +import org.apache.kandula.KandulaException; +import org.apache.kandula.Status; +import org.apache.kandula.coordinator.context.ActivityContext; +import org.apache.kandula.coordinator.context.at.ATActivityContext; +import org.apache.kandula.typemapping.CoordinationContext; +import org.xmlsoap.schemas.ws.x2003.x09.wscoor.CoordinationContextType; + +import junit.framework.TestCase; + +/** + * @author <a href="mailto:[EMAIL PROTECTED]"> Thilina Gunarathne </a> + */ +public class CoordinatorImplTest extends TestCase { + + /* + * @see TestCase#setUp() + */ + protected void setUp() throws Exception { + super.setUp(); + } + + /* + * @see TestCase#tearDown() + */ + protected void tearDown() throws Exception { + super.tearDown(); + } + + /* + * Class under test for ActivityContext createCoordinationContext(String, long) + */ + public void testCreateCoordinationContextStringlong() throws KandulaException { + CoordinatorImpl coordinator = new CoordinatorImpl(); + ActivityContext 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) + */ + public void testCreateCoordinationContextCoordinationContext() throws KandulaException { + CoordinatorImpl coordinator = new CoordinatorImpl(); + CoordinationContext coorContext = CoordinationContext.Factory.newInstance(); + coorContext.setCoordinationType(Constants.WS_AT); + coorContext.setExpires(3000); + coorContext.setActivityID("uuid:29919219jdk02102021"); + // coorContext.setRegistrationService() + ActivityContext 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()); + } + + public void testRegisterParticipant() { + //TODO Implement registerParticipant(). + } + +} Added: 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=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/at/ATCoordinatorTest.java (added) +++ webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/at/ATCoordinatorTest.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,49 @@ +/* + * Copyright 2004 The Apache Software Foundation. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ +package org.apache.kandula.coordinator.at; + +import junit.framework.TestCase; + +/** + * @author <a href="mailto:[EMAIL PROTECTED]"> Thilina Gunarathne </a> + */ +public class ATCoordinatorTest extends TestCase { + + /* + * @see TestCase#setUp() + */ + protected void setUp() throws Exception { + super.setUp(); + } + + /** + * Constructor for ATCoordinatorTest. + * @param arg0 + */ + public ATCoordinatorTest(String arg0) { + super(arg0); + } + + public void testCommitOperation() { + //TODO Implement commitOperation(). + } + + public void testRollbackOperation() { + //TODO Implement rollbackOperation(). + } + +} Added: webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/context/ActivityContextTest.java URL: http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/context/ActivityContextTest.java?rev=233989&view=auto ============================================================================== --- webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/context/ActivityContextTest.java (added) +++ webservices/kandula/trunk/java/test/org/apache/kandula/coordinator/context/ActivityContextTest.java Fri Aug 19 19:59:21 2005 @@ -0,0 +1,50 @@ +/* + * Copyright 2004 The Apache Software Foundation. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ +package org.apache.kandula.coordinator.context; + +import junit.framework.TestCase; + +/** + * @author <a href="mailto:[EMAIL PROTECTED]"> Thilina Gunarathne </a> + */ +public class ActivityContextTest extends TestCase { + + public void testGetActivityID() { + //TODO Implement getActivityID(). + } + + public void testAddParticipant() { + //TODO Implement addParticipant(). + } + + public void testGetStatus() { + //TODO Implement getStatus(). + } + + public void testSetStatus() { + //TODO Implement setStatus(). + } + + public void testLock() { + //TODO Implement lock(). + } + + public void testUnlock() { + //TODO Implement unlock(). + } + +} --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]
