You are viewing a plain text version of this content. The canonical link for it is here.
Posted to kandula-dev@ws.apache.org by th...@apache.org on 2007/02/14 12:08:26 UTC
svn commit: r507487 [4/4] - in
/webservices/kandula/trunk/java/src/org/apache/kandula: ./ ba/ context/
context/impl/ coordinator/ coordinator/at/ coordinator/ba/ initiator/
participant/ participant/at/ participant/ba/ storage/ utility/ wsat/twopc/
wsba...
Added: webservices/kandula/trunk/java/src/org/apache/kandula/wsba/BACoordinatorCompletionParticipantServiceSkeleton.java
URL: http://svn.apache.org/viewvc/webservices/kandula/trunk/java/src/org/apache/kandula/wsba/BACoordinatorCompletionParticipantServiceSkeleton.java?view=auto&rev=507487
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsba/BACoordinatorCompletionParticipantServiceSkeleton.java (added)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsba/BACoordinatorCompletionParticipantServiceSkeleton.java Wed Feb 14 03:08:23 2007
@@ -0,0 +1,289 @@
+/*
+ * 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.wsba;
+
+import org.apache.axiom.om.OMElement;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.context.MessageContext;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.kandula.Constants;
+import org.apache.kandula.context.AbstractContext;
+import org.apache.kandula.context.impl.ParticipantContext;
+import org.apache.kandula.faults.AbstractKandulaException;
+import org.apache.kandula.faults.NoActivityException;
+import org.apache.kandula.participant.ba.BAParticipantTransactionCoordinator;
+import org.apache.kandula.storage.StorageUtils;
+
+/**
+ * BACoordinatorCompletionParticipantServiceSkeleton java skeleton for the
+ * axisService
+ */
+public class BACoordinatorCompletionParticipantServiceSkeleton {
+
+ private static final Log log = LogFactory
+ .getLog(BACoordinatorCompletionParticipantServiceSkeleton.class);
+
+ public void CloseOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Close param1)
+ throws AxisFault {
+ OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+ OMElement firstChildWithName = header
+ .getFirstChildWithName(Constants.REQUESTER_ID_PARAMETER);
+ if (firstChildWithName != null) {
+ String requesterID = firstChildWithName.getText();
+ AbstractContext context2 = StorageUtils.getContext(requesterID);
+ try {
+ if (context2!=null)
+ {
+ ParticipantContext context = (ParticipantContext) context2;
+ BAParticipantTransactionCoordinator participantCoordinator = new BAParticipantTransactionCoordinator();
+ participantCoordinator.close(context);
+ }else {
+ log.fatal("WS_BA : message "+ MessageContext.getCurrentMessageContext().getMessageID()
+ + " : CompensatedOperation : Business Activity Not Found");
+ throw new NoActivityException("CompensateOperation : Business Activity Not Found");
+ }
+ } catch (AbstractKandulaException e) {
+ log.fatal("WS_BA : Message ID : " + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : close Operation :" + e);
+ throw new AxisFault(e);
+ }
+ } else {
+ AxisFault e = new AxisFault(
+ "Requester ID header is not found in the message. Please check whether ws-addressing is enabled in the coordinator.");
+ log.fatal("WS_BA : Message ID "
+ + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : CloseOperation :" + e);
+ throw e;
+ }
+ }
+
+ public void CompleteOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Complete param4)
+ throws AxisFault {
+ OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+ OMElement firstChildWithName = header
+ .getFirstChildWithName(Constants.REQUESTER_ID_PARAMETER);
+ if (firstChildWithName != null) {
+ String requesterID = firstChildWithName.getText();
+ AbstractContext context2 = StorageUtils.getContext(requesterID);
+ if (context2 != null) {
+ ParticipantContext context = (ParticipantContext) context2;
+ BAParticipantTransactionCoordinator participantCoordinator = new BAParticipantTransactionCoordinator();
+ try {
+ participantCoordinator.complete(context);
+ } catch (AbstractKandulaException e) {
+ log.fatal("WS_BA : " + context.getCoordinationContext().getActivityID()
+ + " : Complete Operation :" + e);
+ throw new AxisFault(e);
+ }
+ } else {
+ log.fatal("WS_BA : Message ID "
+ + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : CompleteOperation : Participant Context Not Found.");
+ throw new AxisFault("CompleteOperation : Participant Context Not Found.");
+ }
+ } else {
+ AxisFault e = new AxisFault(
+ "Requester ID header is not found in the message. Please check whether ws-addressing is enabled in the coordinator.");
+ log.fatal("WS_BA : Message ID "
+ + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : Complete Operation :" + e);
+ throw e;
+ }
+ }
+
+ public void CancelOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Cancel param3)
+ throws AxisFault {
+ OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+ OMElement firstChildWithName = header
+ .getFirstChildWithName(Constants.REQUESTER_ID_PARAMETER);
+ if (firstChildWithName != null) {
+ String requesterID = firstChildWithName.getText();
+ AbstractContext context2 = StorageUtils.getContext(requesterID);
+ if (context2 != null) {
+ ParticipantContext context = (ParticipantContext) context2;
+ BAParticipantTransactionCoordinator participantCoordinator = new BAParticipantTransactionCoordinator();
+ try {
+ participantCoordinator.cancel(context);
+ } catch (AbstractKandulaException e) {
+ log.fatal("WS_BA : " + context.getCoordinationContext().getActivityID()
+ + " : CancelOperation :" + e);
+ throw new AxisFault(e);
+ }
+ } else
+ // participant context migt have been already removed by an earlier
+ // cancel
+ {
+ log.info("WS_BA : Message ID "
+ + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : CancelOperation : Participant Context Not Found.");
+ }
+ } else {
+ AxisFault e = new AxisFault(
+ "Requester ID header is not found in the message. Please check whether ws-addressing is enabled in the coordinator.");
+ log.fatal("WS_BA : Message ID "
+ + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : CancelOperation :" + e);
+ throw e;
+ }
+ }
+
+ public void ExitedOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Exited param8)
+ throws AxisFault
+ {
+ OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+ OMElement firstChildWithName = header
+ .getFirstChildWithName(Constants.REQUESTER_ID_PARAMETER);
+ if (firstChildWithName != null) {
+ String requesterID = firstChildWithName.getText();
+ AbstractContext context2 = StorageUtils.getContext(requesterID);
+ if (context2 != null) {
+ ParticipantContext context = (ParticipantContext) context2;
+ BAParticipantTransactionCoordinator participantCoordinator = new BAParticipantTransactionCoordinator();
+ try {
+ participantCoordinator.exited(context);
+ } catch (AbstractKandulaException e) {
+ log.fatal("WS_BA : " + context.getCoordinationContext().getActivityID()
+ + " : ExitedOperation :" + e);
+ throw new AxisFault(e);
+ }
+ } else
+ // participant context migt have been already removed by an earlier
+ // exited
+ {
+ log.info("WS_BA : Message ID "
+ + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : ExitedOperation : Participant Context Not Found.");
+ }
+ } else {
+ AxisFault e = new AxisFault(
+ "Requester ID header is not found in the message. Please check whether ws-addressing is enabled in the coordinator.");
+ log.fatal("WS_BA : Message ID "
+ + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : ExitedOperation :" + e);
+ throw e;
+ }
+ }
+
+ public void CompensateOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Compensate param2) throws AxisFault
+
+ {
+ OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+ OMElement firstChildWithName = header
+ .getFirstChildWithName(Constants.REQUESTER_ID_PARAMETER);
+ if (firstChildWithName != null) {
+ String requesterID = firstChildWithName.getText();
+ AbstractContext context2 = StorageUtils.getContext(requesterID);
+ try {
+ if (context2 != null) {
+ ParticipantContext context = (ParticipantContext) context2;
+ BAParticipantTransactionCoordinator participantCoordinator = new BAParticipantTransactionCoordinator();
+ participantCoordinator.compensate(context);
+ } else {
+ log.fatal("WS_BA : message "+ MessageContext.getCurrentMessageContext().getMessageID()
+ + " : CompensatedOperation : Business Activity Not Found");
+ throw new NoActivityException("CompensateOperation : Business Activity Not Found");
+ }
+ } catch (AbstractKandulaException e) {
+ log.fatal("WS_BA : Message ID : " + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : CompensateOperation :" + e);
+ throw new AxisFault(e);
+ }
+ } else {
+ AxisFault e = new AxisFault(
+ "Requester ID header is not found in the message. Please check whether ws-addressing is enabled in the coordinator.");
+ log.fatal("WS_BA : Message ID "
+ + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : CompensateOperation :" + e);
+ throw e;
+ }
+ }
+
+ public void FailedOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Failed param0) throws AxisFault
+
+ {
+ OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+ OMElement firstChildWithName = header
+ .getFirstChildWithName(Constants.REQUESTER_ID_PARAMETER);
+ if (firstChildWithName != null) {
+ String requesterID = firstChildWithName.getText();
+ AbstractContext context2 = StorageUtils.getContext(requesterID);
+ if (context2 != null) {
+ ParticipantContext context = (ParticipantContext) context2;
+ BAParticipantTransactionCoordinator participantCoordinator = new BAParticipantTransactionCoordinator();
+ try {
+ participantCoordinator.Faulted(context);
+ } catch (AbstractKandulaException e) {
+ log.fatal("WS_BA : " + context.getCoordinationContext().getActivityID()
+ + " : FailedOperation :" + e);
+ throw new AxisFault(e);
+ }
+ } else
+ // participant context migt have been already removed by an earlier
+ // exited
+ {
+ log.info("WS_BA : Message ID "
+ + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : FailedOperation : Participant Context Not Found.");
+ }
+ } else {
+ AxisFault e = new AxisFault(
+ "Requester ID header is not found in the message. Please check whether ws-addressing is enabled in the coordinator.");
+ log.fatal("WS_BA : Message ID "
+ + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : FailedOperation :" + e);
+ throw e;
+ }
+ }
+
+ /**
+ * Auto generated method signature
+ *
+ * @param param5
+ *
+ */
+ public void GetStatusOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.GetStatus param5) {
+ // Todo fill this with the necessary business logic
+ }
+
+ /**
+ * Auto generated method signature
+ *
+ * @param param6
+ *
+ */
+ public void NotCompleted(org.oasis_open.docs.ws_tx.wsba._2006._06.NotCompleted param6)
+
+ {
+ // Todo fill this with the necessary business logic
+
+ }
+
+ /**
+ * Auto generated method signature
+ *
+ * @param param7
+ *
+ */
+ public void StatusOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Status param7)
+
+ {
+ // Todo fill this with the necessary business logic
+
+ }
+}
Added: webservices/kandula/trunk/java/src/org/apache/kandula/wsba/BAParticipantCompletionCoordinatorServiceSkeleton.java
URL: http://svn.apache.org/viewvc/webservices/kandula/trunk/java/src/org/apache/kandula/wsba/BAParticipantCompletionCoordinatorServiceSkeleton.java?view=auto&rev=507487
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsba/BAParticipantCompletionCoordinatorServiceSkeleton.java (added)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsba/BAParticipantCompletionCoordinatorServiceSkeleton.java Wed Feb 14 03:08:23 2007
@@ -0,0 +1,180 @@
+package org.apache.kandula.wsba;
+
+import org.apache.axiom.om.OMElement;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.context.MessageContext;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.kandula.Constants;
+import org.apache.kandula.context.AbstractContext;
+import org.apache.kandula.context.impl.BAActivityContext;
+import org.apache.kandula.coordinator.ba.BACoordinator;
+import org.apache.kandula.faults.AbstractKandulaException;
+import org.apache.kandula.storage.StorageUtils;
+
+/**
+ * BAParticipantCompletionCoordinatorServiceSkeleton java skeleton for the
+ * axisService
+ */
+public class BAParticipantCompletionCoordinatorServiceSkeleton {
+
+ private static final Log log = LogFactory
+ .getLog(BAParticipantCompletionCoordinatorServiceSkeleton.class);
+
+ public void CompletedOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Completed param3)
+ throws AxisFault
+
+ {
+ OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+ String activityId = header.getFirstChildWithName(Constants.TRANSACTION_ID_PARAMETER)
+ .getText();
+ String enlistmentId = header.getFirstChildWithName(Constants.ENLISTMENT_ID_PARAMETER)
+ .getText();
+ try {
+ BAActivityContext baContext = (BAActivityContext) StorageUtils.getContext(activityId);
+ BACoordinator atomicBACoordinator = new BACoordinator();
+ atomicBACoordinator.completedOperation(baContext, enlistmentId);
+ } catch (AbstractKandulaException e) {
+ log.fatal("WS_BA : message " + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : CompletedOperation :" + e);
+ throw new AxisFault(e);
+ }
+ }
+
+ public void ClosedOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Closed param1)
+ throws AxisFault
+
+ {
+ OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+ String activityId = header.getFirstChildWithName(Constants.TRANSACTION_ID_PARAMETER)
+ .getText();
+ String enlistmentId = header.getFirstChildWithName(Constants.ENLISTMENT_ID_PARAMETER)
+ .getText();
+ try {
+ AbstractContext context = StorageUtils.getContext(activityId);
+ if (context != null) {
+ BAActivityContext baContext = (BAActivityContext) context;
+ BACoordinator atomicBACoordinator = new BACoordinator();
+ atomicBACoordinator.closedOperation(baContext, enlistmentId);
+ }
+ } catch (AbstractKandulaException e) {
+ log.fatal("WS_BA : message " + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : ClosedOperation :" + e);
+ throw new AxisFault(e);
+ }
+ }
+
+ public void CanceledOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Canceled param8) throws AxisFault
+
+ {
+ OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+ String activityId = header.getFirstChildWithName(Constants.TRANSACTION_ID_PARAMETER)
+ .getText();
+ String enlistmentId = header.getFirstChildWithName(Constants.ENLISTMENT_ID_PARAMETER)
+ .getText();
+ try {
+ AbstractContext context = StorageUtils.getContext(activityId);
+ if (context != null) {
+ BAActivityContext baContext = (BAActivityContext) context;
+ BACoordinator atomicBACoordinator = new BACoordinator();
+ atomicBACoordinator.canceledOperation(baContext, enlistmentId);
+ }
+ } catch (AbstractKandulaException e) {
+ log.fatal("WS_BA : message " + MessageContext.getCurrentMessageContext().getMessageID()
+ + " : CanceledOperation :" + e);
+ throw new AxisFault(e);
+ }
+
+ }
+
+ public void CompensatedOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Compensated param0)
+
+ {
+/* try {
+ OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+ String requesterID = header.getFirstChildWithName(Constants.REQUESTER_ID_PARAMETER)
+ .getText();
+ AbstractContext contextx = (AbstractContext) StorageUtils.getContext(requesterID);
+ BAParticipantTransactionSentCoordinator BAStxManager = new BAParticipantTransactionSentCoordinator();
+ BAStxManager.Fault(contextx, Constants.WS_BA_PC);
+ } catch (Exception e) {
+ }
+ // =====================end=========================z //Todo fill this
+ // with the necessary business logic
+*/
+ }
+
+ /**
+ * Auto generated method signature
+ *
+ * @param param2
+ *
+ */
+ public void ExitOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Exit param2)
+
+ {
+ // Todo fill this with the necessary business logic
+ try {
+ OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+ String requesterID = header.getFirstChildWithName(Constants.REQUESTER_ID_PARAMETER)
+ .getText();
+ AbstractContext context = (AbstractContext) StorageUtils.getContext(requesterID);
+ // BAParticipantTransactionSentCoordinator BAStxManager = new
+ // BAParticipantTransactionSentCoordinator();
+ // BAStxManager.exit(context);
+ } catch (Exception e) {
+ }
+ }
+
+ /**
+ * Auto generated method signature
+ *
+ * @param param4
+ *
+ */
+ public void CannotComplete(org.oasis_open.docs.ws_tx.wsba._2006._06.CannotComplete param4)
+
+ {
+ // Todo fill this with the necessary business logic
+
+ }
+
+ /**
+ * Auto generated method signature
+ *
+ * @param param5
+ *
+ */
+ public void GetStatusOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.GetStatus param5)
+
+ {
+ // Todo fill this with the necessary business logic
+
+ }
+
+ /**
+ * Auto generated method signature
+ *
+ * @param param6
+ *
+ */
+ public void FailOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Fail param6)
+
+ {
+ // Todo fill this with the necessary business logic
+
+ }
+
+ /**
+ * Auto generated method signature
+ *
+ * @param param7
+ *
+ */
+ public void StatusOperation(org.oasis_open.docs.ws_tx.wsba._2006._06.Status param7)
+
+ {
+ // Todo fill this with the necessary business logic
+
+ }
+}
Added: webservices/kandula/trunk/java/src/org/apache/kandula/wsba/BAParticipantCompletionParticipantServiceSkeleton.java
URL: http://svn.apache.org/viewvc/webservices/kandula/trunk/java/src/org/apache/kandula/wsba/BAParticipantCompletionParticipantServiceSkeleton.java?view=auto&rev=507487
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wsba/BAParticipantCompletionParticipantServiceSkeleton.java (added)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wsba/BAParticipantCompletionParticipantServiceSkeleton.java Wed Feb 14 03:08:23 2007
@@ -0,0 +1,220 @@
+
+ /**
+ * BAParticipantCompletionParticipantServiceSkeleton.java
+ *
+ * This file was auto-generated from WSDL
+ * by the Apache Axis2 version: #axisVersion# #today#
+ */
+ package org.apache.kandula.wsba;
+
+import org.apache.axiom.om.OMElement;
+import org.apache.axis2.context.MessageContext;
+import org.apache.kandula.Constants;
+import org.apache.kandula.context.AbstractContext;
+import org.apache.kandula.faults.AbstractKandulaException;
+import org.apache.kandula.participant.ba.BAParticipantTransactionCoordinator;
+import org.apache.kandula.storage.Store;
+ /**
+ * BAParticipantCompletionParticipantServiceSkeleton java skeleton for the axisService
+ */
+ public class BAParticipantCompletionParticipantServiceSkeleton{
+
+
+ /**
+ * Auto generated method signature
+
+ * @param param0
+
+ */
+ public void FailedOperation
+ (
+ org.oasis_open.docs.ws_tx.wsba._2006._06.Failed param0
+ )
+
+ {
+ //==filed by nis===========================================
+ try{
+// StorageFactory.getInstance().setConfigurationContext(
+// MessageContext.getCurrentMessageContext().getServiceContext().getConfigurationContext());
+// OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+// String requesterID = header.getFirstChildWithName(
+// Constants.REQUESTER_ID_PARAMETER).getText();
+// Store store = StorageFactory.getInstance().getStore();
+// AbstractContext context = (AbstractContext) store.get(requesterID);
+// BAParticipantTransactionCoordinator BAtxManager = new BAParticipantTransactionCoordinator();
+// BAtxManager.Faulted(context,Constants.WS_BA_PC);
+ }catch(Exception e){}
+ //=====================end=========================z
+
+ }
+
+
+ /**
+ * Auto generated method signature
+
+ * @param param1
+
+ */
+ public void CloseOperation
+ (
+ org.oasis_open.docs.ws_tx.wsba._2006._06.Close param1
+ )
+
+ {
+ try{
+ //==============filled by nis======================
+// StorageFactory.getInstance().setConfigurationContext(
+// MessageContext.getCurrentMessageContext().getServiceContext().getConfigurationContext());
+// OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+// String requesterID = header.getFirstChildWithName(
+// Constants.REQUESTER_ID_PARAMETER).getText();
+// Store store = StorageFactory.getInstance().getStore();
+// AbstractContext context = (AbstractContext) store.get(requesterID);
+// BAParticipantTransactionCoordinator BAtxManager = new BAParticipantTransactionCoordinator();
+// BAtxManager.Close(context,Constants.WS_BA_PC);
+ }catch(Exception e){}
+
+ //=====================end===============================
+ //Todo fill this with the necessary business logic
+
+ }
+
+
+ /**
+ * Auto generated method signature
+
+ * @param param2
+
+ */
+ public void CompensateOperation
+ (
+ org.oasis_open.docs.ws_tx.wsba._2006._06.Compensate param2
+ )
+
+ {
+ try{
+ // == filled by nis===============================
+// StorageFactory.getInstance().setConfigurationContext(
+// MessageContext.getCurrentMessageContext().getServiceContext().getConfigurationContext());
+// OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+// String requesterID = header.getFirstChildWithName(
+// Constants.REQUESTER_ID_PARAMETER).getText();
+// Store store = StorageFactory.getInstance().getStore();
+// AbstractContext context = (AbstractContext) store.get(requesterID);
+// BAParticipantTransactionCoordinator batxManager = new BAParticipantTransactionCoordinator();
+//
+// batxManager.Compensate(context,Constants.WS_BA_PC);//Todo fill this with the necessary business logic
+ //=====================end===================================
+ }catch(Exception e){
+
+
+ } }
+
+
+ /**
+ * Auto generated method signature
+
+ * @param param3
+
+ */
+ public void CancelOperation( org.oasis_open.docs.ws_tx.wsba._2006._06.Cancel param3)
+ {
+// StorageFactory.getInstance().setConfigurationContext(
+// MessageContext.getCurrentMessageContext().getServiceContext().getConfigurationContext());
+// OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+// String requesterID = header.getFirstChildWithName(
+// Constants.REQUESTER_ID_PARAMETER).getText();
+// Store store = StorageFactory.getInstance().getStore();
+// AbstractContext context = (AbstractContext) store.get(requesterID);
+// //Need a BAParticipantTransactionCoordinator
+// BAParticipantTransactionCoordinator baParticipantTxManager = new BAParticipantTransactionCoordinator();
+// try {
+// baParticipantTxManager.Cancel(context,Constants.WS_BA_PC);
+// } catch (AbstractKandulaException e) {
+//
+// }
+
+ }
+
+ /**
+ * Auto generated method signature
+
+ * @param param4
+
+ */
+ public void GetStatusOperation
+ (
+ org.oasis_open.docs.ws_tx.wsba._2006._06.GetStatus param4
+ )
+
+ {
+ //Todo fill this with the necessary business logic
+
+ }
+
+
+ /**
+ * Auto generated method signature
+
+ * @param param5
+
+ */
+ public void NotCompleted
+ (
+ org.oasis_open.docs.ws_tx.wsba._2006._06.NotCompleted param5
+ )
+
+ {
+ //Todo fill this with the necessary business logic
+
+ }
+
+
+ /**
+ * Auto generated method signature
+
+ * @param param6
+
+ */
+ public void StatusOperation
+ (
+ org.oasis_open.docs.ws_tx.wsba._2006._06.Status param6
+ )
+
+ {
+ //Todo fill this with the necessary business logic
+
+ }
+
+
+ /**
+ * Auto generated method signature
+
+ * @param param7
+
+ */
+ public void ExitedOperation
+ (
+ org.oasis_open.docs.ws_tx.wsba._2006._06.Exited param7
+ )
+
+ {
+ try{
+ //== filled by nis===============================
+// StorageFactory.getInstance().setConfigurationContext(
+// MessageContext.getCurrentMessageContext().getServiceContext().getConfigurationContext());
+// OMElement header = MessageContext.getCurrentMessageContext().getEnvelope().getHeader();
+// String requesterID = header.getFirstChildWithName(
+// Constants.REQUESTER_ID_PARAMETER).getText();
+// Store store = StorageFactory.getInstance().getStore();
+// AbstractContext context = (AbstractContext) store.get(requesterID);
+// BAParticipantTransactionCoordinator batxManager = new BAParticipantTransactionCoordinator();
+// //=======================================end=====================
+// batxManager.Exited(context,Constants.WS_BA_PC);
+ }catch(Exception e){
+
+
+ } }
+
+ }
+
\ No newline at end of file
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationServiceSkeleton.java
URL: http://svn.apache.org/viewvc/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationServiceSkeleton.java?view=diff&rev=507487&r1=507486&r2=507487
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationServiceSkeleton.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/ActivationServiceSkeleton.java Wed Feb 14 03:08:23 2007
@@ -69,7 +69,7 @@
Coordinator coordinator = new Coordinator();
AbstractContext context = coordinator.createCoordinationContext(coordinationType,
expiresL);
- StorageUtils.putContext(context);
+// StorageUtils.putContext(context);
CoordinationContext coordinationContext = context.getCoordinationContext();
@@ -82,7 +82,7 @@
coordinationContext_type3.setExpires(expires_type0);
coordinationContext_type3.setRegistrationService(EndpointReferenceFactory
- .getADBEPRTypeFromEPR(coordinationContext.getRegistrationService()));
+ .getEPRTypeFromEPR(coordinationContext.getRegistrationService()));
Identifier_type1 identifier_type1 = new Identifier_type1();
identifier_type1.setAnyURI(new URI("http", "thilina"));
Modified: webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationServiceSkeleton.java
URL: http://svn.apache.org/viewvc/webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationServiceSkeleton.java?view=diff&rev=507487&r1=507486&r2=507487
==============================================================================
--- webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationServiceSkeleton.java (original)
+++ webservices/kandula/trunk/java/src/org/apache/kandula/wscoor/RegistrationServiceSkeleton.java Wed Feb 14 03:08:23 2007
@@ -51,6 +51,7 @@
String protocolIdentifier;
EndpointReference participantEPR;
String activityId;
+ String participantId=null;
/*
* Extracting data from the received message
*/
@@ -63,6 +64,11 @@
.getEnvelope().getHeader();
activityId = header.getFirstChildWithName(
Constants.TRANSACTION_ID_PARAMETER).getText();
+ OMElement participantIDElement = header.getFirstChildWithName(
+ Constants.PARTICIPANT_ID_PARAMETER);
+ if (participantIDElement != null) {
+ participantId = participantIDElement.getText();
+ }
/*
* Registering the participant for the activity for the given protocol
*/
@@ -75,10 +81,10 @@
"No Activity Found for this Activity ID");
}
EndpointReference epr = coordinator.registerParticipant(context,
- protocolIdentifier, participantEPR);
+ protocolIdentifier, participantEPR,participantId);
RegisterResponseType registerResponseType = new RegisterResponseType();
- registerResponseType.setCoordinatorProtocolService(EndpointReferenceFactory.getADBEPRTypeFromEPR(epr));
+ registerResponseType.setCoordinatorProtocolService(EndpointReferenceFactory.getEPRTypeFromEPR(epr));
RegisterResponse registerResponse = new RegisterResponse();
registerResponse.setRegisterResponse(registerResponseType);
return registerResponse;
---------------------------------------------------------------------
To unsubscribe, e-mail: kandula-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: kandula-dev-help@ws.apache.org