| /* |
| * 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.ba; |
| |
| |
| import org.apache.axis2.AxisFault; |
| import org.apache.axis2.addressing.EndpointReference; |
| import org.apache.kandula.Status; |
| import org.apache.kandula.Status.BACoordinatorStatus; |
| import org.apache.kandula.context.AbstractContext; |
| import org.apache.kandula.context.impl.BAActivityContext; |
| import org.apache.kandula.coordinator.Registerable; |
| import org.apache.kandula.faults.AbstractKandulaException; |
| import org.apache.kandula.faults.InvalidStateException; |
| import org.apache.kandula.faults.KandulaGeneralException; |
| import org.apache.kandula.wsba.BACoordinatorCompletionParticipantServiceStub; |
| import org.apache.kandula.wsba.BAParticipantCompletionParticipantServiceStub; |
| import org.oasis_open.docs.ws_tx.wsba._2006._06.Cancel; |
| import org.oasis_open.docs.ws_tx.wsba._2006._06.Close; |
| import org.oasis_open.docs.ws_tx.wsba._2006._06.Compensate; |
| import org.oasis_open.docs.ws_tx.wsba._2006._06.Complete; |
| import org.oasis_open.docs.ws_tx.wsba._2006._06.Exited; |
| import org.oasis_open.docs.ws_tx.wsba._2006._06.Failed; |
| |
| /** |
| * @author <a href="mailto:thilina@opensource.lk"> Thilina Gunarathne </a> |
| */ |
| public class BACoordinator implements Registerable |
| { |
| public BACoordinator() |
| { |
| } |
| |
| //Start - Register |
| /*public EndpointReference register(AbstractContext context, String protocol, |
| EndpointReference participantEPR) throws AbstractKandulaException |
| { |
| EndpointReference registeredParticipantEPR = null; |
| BAActivityContext baContext = (BAActivityContext) context; |
| if(baContext.getCoordinationType().equals(Constants.WS_BA_ATOMIC)) |
| { |
| AtomicBACoordinator atomicBACoordinator = new AtomicBACoordinator(); |
| registeredParticipantEPR = atomicBACoordinator.registerBAAtomicParticipants(baContext,protocol,participantEPR); |
| } |
| if(baContext.getCoordinationType().equals(Constants.WS_BA_MIXED)) |
| { |
| MixedBACoordinator mixedBACoordinator = new MixedBACoordinator(); |
| registeredParticipantEPR = mixedBACoordinator.registerBAMixedParticipants(baContext,protocol,participantEPR); |
| } |
| return registeredParticipantEPR; |
| }*/ |
| //End -Register |
| |
| public EndpointReference register(AbstractContext context, String protocol, |
| EndpointReference participantEPR)throws AbstractKandulaException |
| { |
| BAActivityContext baContext = (BAActivityContext) context; |
| baContext.lock(); |
| int coordinatorStatus = baContext.getStatus(); |
| if(coordinatorStatus ==(BACoordinatorStatus.STATUS_CLOSING)) |
| { |
| baContext.unlock(); |
| throw new InvalidStateException ("Coordinator is in closing status "); |
| }else if(coordinatorStatus ==(BACoordinatorStatus.STATUS_COMPENSATING)) |
| { |
| baContext.unlock(); |
| throw new InvalidStateException ("Coordinator is in compensating status "); |
| } |
| else |
| { |
| EndpointReference epr = baContext.addParticipant(participantEPR, |
| protocol); |
| baContext.unlock(); |
| return epr; |
| } |
| } |
| |
| /** |
| * Coordinator View of BusinessAgreement with Participant Completion |
| */ |
| //********************************************************************************* |
| /* |
| * Handling Protocol Messages recieved by the Coordinator[sent by participant] </a> |
| */ |
| |
| // 1. Start Exit |
| // If a exit is recieved the the coordinator removes that participant from the list |
| // public void PCExitOperation(AbstractContext context, String enlishmentID) |
| // throws AbstractKandulaException |
| // { |
| // BAActivityContext baContext = (BAActivityContext) context; |
| // baContext.lock(); |
| // BAParticipantInformation baParticipantInfo = baContext.getParticipant(enlishmentID); |
| // switch(baContext.getStatus()) |
| // { |
| // |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // try{ |
| // baContext.removeParticipant(enlishmentID); |
| // int existingCount = baContext.getParticipantCount(); |
| // baContext.setParticipantCount(existingCount--); |
| // baParticipantInfo.setStatus(Status.BACoordinatorStatus.STATUS_EXITING); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_EXITING); |
| // baContext.unlock(); |
| // this.PCExitedOperation(baContext,enlishmentID); |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // try{ |
| // baContext.removeParticipant(enlishmentID); |
| // int existingCount = baContext.getParticipantCount(); |
| // baContext.setParticipantCount(existingCount--); |
| // // Take an iterator |
| // baParticipantInfo.setStatus(Status.BACoordinatorStatus.STATUS_EXITING); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_EXITING); |
| // baContext.unlock(); |
| // this.PCExitedOperation(baContext,enlishmentID); |
| // |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // try{ |
| // baContext.unlock(); |
| // this.PCExitedOperation(baContext,enlishmentID); |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting compensatingstate"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting active state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // } |
| // } |
| // //End Exit |
| // |
| // //2. start Completed |
| // public void PCCompletedOperation(BAActivityContext baContext, String enlishmentID) |
| // throws AbstractKandulaException |
| // { |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting active state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting active state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // } |
| // } |
| // //EndCompleted |
| // |
| // // 3. Start - Fault |
| // public void PCFaultOperation(AbstractContext context, String enlishmentID) |
| // throws AbstractKandulaException |
| // { |
| // BAActivityContext baContext = (BAActivityContext) context; |
| // baContext.lock(); |
| // BAParticipantInformation baParticipantInformation= baContext.getParticipant(enlishmentID); |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // try{ |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING_ACTIVE); |
| // baContext.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING_ACTIVE); |
| // baContext.unlock(); |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // try{ |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING_ACTIVE); |
| // baContext.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING_ACTIVE); |
| // baContext.unlock(); |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // try{ |
| // |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING_COMPENSATING); |
| // baContext.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING_COMPENSATING); |
| // baContext.unlock(); |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_COMPENSATING: |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.unlock(); |
| // this.PCFaultedOperation(baContext,enlishmentID); |
| // |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_ACTIVE: |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.unlock(); |
| // this.PCFaultedOperation(baContext,enlishmentID); |
| // |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // this.PCFaultedOperation(baContext,enlishmentID); |
| // |
| // } |
| // } |
| // //End - Fault |
| // |
| // //4. Canceled |
| // public void PCCanceledOperation(BAActivityContext baContext,String enlishmentID) |
| // throws AbstractKandulaException |
| // { |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in Active state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in cLOSING state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting Compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting active state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // } |
| // } |
| // //End Canceled |
| // |
| // //5.Start -Closed |
| // public void PCClosedOperation(BAActivityContext baContext,String enlishmentID) |
| // throws AbstractKandulaException |
| // { |
| // BAParticipantInformation baPaticipantInformation = baContext.getParticipant(enlishmentID); |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in Active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in canceling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baPaticipantInformation.setStatus(BACoordinatorStatus.STATUS_ENDED); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_ENDED); |
| // baContext.unlock(); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting Compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting active state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // } |
| // } |
| // //End Closed |
| // |
| // // Start - Compensated |
| // public void PCCompensatedOperation(BAActivityContext baContext,String enlishmentID) |
| // throws AbstractKandulaException |
| // { |
| // BAParticipantInformation baPaticipantInformation = baContext.getParticipant(enlishmentID); |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in Active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in canceling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baPaticipantInformation.setStatus(BACoordinatorStatus.STATUS_ENDED); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_ENDED); |
| // baContext.unlock(); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting Compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting active state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // } |
| // } |
| // //End -Compensated |
| // |
| ///** |
| // * Handling Protocol Messages sent by the Coordinator[recieved by participant] </a> |
| // */ |
| // |
| ////start - Cancel |
| //public void PCCancelOperation(AbstractContext context,String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAActivityContext baContext = (BAActivityContext) context; |
| // baContext.lock(); |
| // BAParticipantInformation cancelingParticipant = baContext.getParticipant(enlishmentID); |
| // BAParticipantCompletionParticipantServiceStub pcpsStub; |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // try{ |
| // pcpsStub = new BAParticipantCompletionParticipantServiceStub(((cancelingParticipant.getEpr()).toString())); |
| // Cancel cancelParam = new Cancel(); |
| // pcpsStub.CancelOperation(cancelParam); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_CANCELLING_ACTIVE); |
| // cancelingParticipant.setStatus(BACoordinatorStatus.STATUS_CANCELLING_ACTIVE); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // try{ |
| // |
| // pcpsStub = new BAParticipantCompletionParticipantServiceStub(((cancelingParticipant.getEpr()).toString())); |
| // Cancel cancelParam = new Cancel(); |
| // pcpsStub.CancelOperation(cancelParam); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensated state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in ended state"); |
| // } |
| //}//End Cancel |
| // |
| ////Start Colse |
| //public void PCCloseOperation(BAActivityContext baContext, String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAParticipantInformation baParticipantInformation = baContext.getParticipant(enlishmentID); |
| // baContext.lock(); |
| // BAParticipantCompletionParticipantServiceStub pcpsStub; |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in cancelling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // try{ |
| // String participantEndpointReference = baParticipantInformation.getEpr().toString(); |
| // pcpsStub = new BAParticipantCompletionParticipantServiceStub(participantEndpointReference); |
| // Close closeParam = new Close(); |
| // pcpsStub.CloseOperation(closeParam); |
| // baParticipantInformation.setStatus(BACoordinatorStatus.STATUS_CLOSING); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // try{ |
| // |
| // String participantEndpointReference = baParticipantInformation.getEpr().toString(); |
| // pcpsStub = new BAParticipantCompletionParticipantServiceStub(participantEndpointReference); |
| // Close closeParam = new Close(); |
| // pcpsStub.CloseOperation(closeParam); |
| // baParticipantInformation.setStatus(BACoordinatorStatus.STATUS_CLOSING); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // } |
| //}//End - Close |
| // |
| ////Start - Compensate |
| //public void PCCompensateOperation(BAActivityContext baContext, String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAParticipantInformation baParticipantInformation = baContext.getParticipant(enlishmentID); |
| // baContext.lock(); |
| // BAParticipantCompletionParticipantServiceStub pcpsStub; |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in cancelling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // try{ |
| // String participantEndpointReference = baParticipantInformation.getEpr().toString(); |
| // pcpsStub = new BAParticipantCompletionParticipantServiceStub(participantEndpointReference); |
| // Compensate compensateParam = new Compensate(); |
| // pcpsStub.CompensateOperation(compensateParam); |
| // baParticipantInformation.setStatus(BACoordinatorStatus.STATUS_COMPENSATING); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in cancelling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // try{ |
| // String participantEndpointReference = baParticipantInformation.getEpr().toString(); |
| // pcpsStub = new BAParticipantCompletionParticipantServiceStub(participantEndpointReference); |
| // Compensate compensateParam = new Compensate(); |
| // pcpsStub.CompensateOperation(compensateParam); |
| // baParticipantInformation.setStatus(BACoordinatorStatus.STATUS_COMPENSATING); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // } |
| //}//End - Compensate |
| // |
| ////Start Faulted |
| //public void PCFaultedOperation(BAActivityContext baContext, String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // baContext.lock(); |
| // BAParticipantInformation baParticipantInformation = baContext.getParticipant(enlishmentID); |
| // BAParticipantCompletionParticipantServiceStub pcpsStub; |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in cancelling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING: |
| // try{ |
| // String participantEndpointReference = baParticipantInformation.getEpr().toString(); |
| // pcpsStub = new BAParticipantCompletionParticipantServiceStub(participantEndpointReference); |
| // Failed failedParam = new Failed(); |
| // pcpsStub.FailedOperation(failedParam); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_ENDED); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_ENDED); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // try{ |
| // String participantEndpointReference = baParticipantInformation.getEpr().toString(); |
| // pcpsStub = new BAParticipantCompletionParticipantServiceStub(participantEndpointReference); |
| // Failed failedParam = new Failed(); |
| // pcpsStub.FailedOperation(failedParam); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // } |
| //} |
| ////End Faulted |
| // |
| ////Start - Exited |
| //public void PCExitedOperation(AbstractContext context, String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAParticipantCompletionParticipantServiceStub pcpsStub; |
| // BAActivityContext baContext = (BAActivityContext) context; |
| // baContext.lock(); |
| // BAParticipantInformation exitingParticipant = baContext.getParticipant(enlishmentID); |
| // |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in canceling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // try{ |
| // pcpsStub = new BAParticipantCompletionParticipantServiceStub(((exitingParticipant.getEpr()).toString())); |
| // Exited exitedParam = new Exited(); |
| // pcpsStub.ExitedOperation(exitedParam); |
| // exitingParticipant.setStatus(Status.BACoordinatorStatus.STATUS_ENDED); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_ENDED); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // try{ |
| // pcpsStub = new BAParticipantCompletionParticipantServiceStub(((exitingParticipant.getEpr()).toString())); |
| // Exited exitedParam = new Exited(); |
| // pcpsStub.ExitedOperation(exitedParam); |
| // baContext.setStatus(Status.BACoordinatorStatus.STATUS_ENDED); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // } |
| //} |
| ////End Exited |
| // |
| ////*********************************************************************************** |
| ///** |
| // * Coordinator View of BusinessAgreement with Coordinator Completion |
| // */ |
| // |
| ///** |
| // * Handling Protocol Messages recieved by the Coordinator[sent by participant] </a> |
| // */ |
| ////1. Start CCExit |
| //public void CCExitOperation(AbstractContext context, String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAActivityContext baContext = (BAActivityContext) context; |
| // baContext.lock(); |
| // BAParticipantInformation baParticipantInfo = baContext.getParticipant(enlishmentID); |
| // switch(baContext.getStatus()) |
| // { |
| // |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // try{ |
| // baContext.removeParticipant(enlishmentID); |
| // int existingCount = baContext.getParticipantCount(); |
| // baContext.setParticipantCount(existingCount--); |
| // baParticipantInfo.setStatus(Status.BACoordinatorStatus.STATUS_EXITING); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_EXITING); |
| // baContext.unlock(); |
| // this.CCExitedOperation(baContext,enlishmentID); |
| // |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // try{ |
| // baContext.removeParticipant(enlishmentID); |
| // int existingCount = baContext.getParticipantCount(); |
| // baContext.setParticipantCount(existingCount--); |
| // baParticipantInfo.setStatus(Status.BACoordinatorStatus.STATUS_EXITING); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_EXITING); |
| // baContext.unlock(); |
| // this.CCExitedOperation(baContext,enlishmentID); |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_CANCELING_COMPLETING: |
| // try{ |
| // baContext.removeParticipant(enlishmentID); |
| // int existingCount = baContext.getParticipantCount(); |
| // baContext.setParticipantCount(existingCount--); |
| // baParticipantInfo.setStatus(Status.BACoordinatorStatus.STATUS_EXITING); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_EXITING); |
| // baContext.unlock(); |
| // this.CCExitedOperation(baContext,enlishmentID); |
| // |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting compensatingstate"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting active state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // try{ |
| // baContext.unlock(); |
| // this.CCExitedOperation(baContext,enlishmentID); |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // } |
| // } |
| ////End CCExit |
| // |
| ////2. start CCCompleted |
| //public void CCCompletedOperation(BAActivityContext baContext, String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAParticipantInformation baParticipantInformation= baContext.getParticipant(enlishmentID); |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING_ACTIVE: |
| // baContext.setStatus(BACoordinatorStatus.STATUS_CANCELLING); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_CANCELLING); |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in canceling active state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // CCCloseOperation(baContext,enlishmentID); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting active state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_COMPENSATING: |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_ACTIVE: |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // } |
| //} |
| ////End - CCCompleted |
| // |
| //// 3. Start - Fault |
| //public void CCFaultOperation(AbstractContext context, String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAActivityContext baContext = (BAActivityContext) context; |
| // baContext.lock(); |
| // BAParticipantInformation baParticipantInformation= baContext.getParticipant(enlishmentID); |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // try{ |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING_ACTIVE); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING_ACTIVE); |
| // baContext.unlock(); |
| // this.CCFaultedOperation(baContext,enlishmentID); |
| // |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING_ACTIVE: |
| // try{ |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING_ACTIVE); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING_ACTIVE); |
| // baContext.unlock(); |
| // this.CCFaultedOperation(baContext,enlishmentID); |
| // |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_CANCELING_COMPLETING: |
| // try{ |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING_ACTIVE); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING_ACTIVE); |
| // baContext.unlock(); |
| // this.CCFaultedOperation(baContext,enlishmentID); |
| // |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETING: |
| // try{ |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING_ACTIVE); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING_ACTIVE); |
| // baContext.unlock(); |
| // this.CCFaultedOperation(baContext,enlishmentID); |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // try{ |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING_COMPENSATING); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING_COMPENSATING); |
| // this.CCFaultedOperation(baContext,enlishmentID); |
| // baContext.unlock(); |
| // } |
| // catch(Exception e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_COMPENSATING: |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.unlock(); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_ACTIVE: |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.unlock(); |
| // this.PCFaultedOperation(baContext,enlishmentID); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // } |
| //} |
| ////End - Fault |
| // |
| ////4. Canceled |
| //public void CCCanceledOperation(BAActivityContext baContext,String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAParticipantInformation baParticipantInformation = baContext.getParticipant(enlishmentID); |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in Active state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_COMPENSATING: |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting Compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_ACTIVE: |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting active state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // } |
| // } |
| ////End Canceled |
| // |
| ////5.Start -Closed |
| //public void CCClosedOperation(BAActivityContext baContext,String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAParticipantInformation baPaticipantInformation = baContext.getParticipant(enlishmentID); |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in Active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING_ACTIVE: |
| // baPaticipantInformation.setStatus(BACoordinatorStatus.STATUS_CANCELLING); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_CANCELLING); |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in canceling active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELING_COMPLETING: |
| // baPaticipantInformation.setStatus(BACoordinatorStatus.STATUS_CANCELLING); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_CANCELLING); |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in canceling completing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baPaticipantInformation.setStatus(BACoordinatorStatus.STATUS_ENDED); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_ENDED); |
| // baContext.unlock(); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_COMPENSATING: |
| // baPaticipantInformation.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting Compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_ACTIVE: |
| // baPaticipantInformation.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting active state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // } |
| // } |
| ////End Closed |
| // |
| //// Start - Compensated |
| //public void CCCompensatedOperation(BAActivityContext baContext,String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAParticipantInformation baPaticipantInformation = baContext.getParticipant(enlishmentID); |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in Active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING_ACTIVE: |
| // baPaticipantInformation.setStatus(BACoordinatorStatus.STATUS_CANCELLING); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_CANCELLING); |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in canceling active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELING_COMPLETING: |
| // baPaticipantInformation.setStatus(BACoordinatorStatus.STATUS_CANCELLING); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_CANCELLING); |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in canceling completing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baPaticipantInformation.setStatus(BACoordinatorStatus.STATUS_ENDED); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_ENDED); |
| // baContext.unlock(); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_COMPENSATING: |
| // baPaticipantInformation.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting Compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING_ACTIVE: |
| // baPaticipantInformation.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_FAULTING); |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting active state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // } |
| // } |
| ////End -Compensated |
| // |
| ///** |
| // * Handling Protocol Messages sent by the Coordinator[sent by participant] </a> |
| // */ |
| // |
| //public void CCCancelOperation(AbstractContext context,String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAActivityContext baContext = (BAActivityContext) context; |
| // baContext.lock(); |
| // BAParticipantInformation cancelingParticipant = baContext.getParticipant(enlishmentID); |
| // BACoordinatorCompletionParticipantServiceStub ccpsStub; |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // try{ |
| // ccpsStub = new BACoordinatorCompletionParticipantServiceStub(((cancelingParticipant.getEpr()).toString())); |
| // Cancel cancelParam = new Cancel(); |
| // ccpsStub.CancelOperation(cancelParam); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_CANCELLING_ACTIVE); |
| // cancelingParticipant.setStatus(BACoordinatorStatus.STATUS_CANCELLING_ACTIVE); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // try{ |
| // |
| // ccpsStub = new BACoordinatorCompletionParticipantServiceStub(((cancelingParticipant.getEpr()).toString())); |
| // Cancel cancelParam = new Cancel(); |
| // ccpsStub.CancelOperation(cancelParam); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETING: |
| // try{ |
| // |
| // ccpsStub = new BACoordinatorCompletionParticipantServiceStub(((cancelingParticipant.getEpr()).toString())); |
| // Cancel cancelParam = new Cancel(); |
| // ccpsStub.CancelOperation(cancelParam); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_CANCELING_COMPLETING); |
| // cancelingParticipant.setStatus(BACoordinatorStatus.STATUS_CANCELING_COMPLETING); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensated state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in ended state"); |
| // } |
| //}//End Cancel |
| // |
| ////Start - Complete |
| //public void CCCompleteOperation(AbstractContext context,String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAActivityContext baContext = (BAActivityContext) context; |
| // baContext.lock(); |
| // BAParticipantInformation cancelingParticipant = baContext.getParticipant(enlishmentID); |
| // BACoordinatorCompletionParticipantServiceStub ccpsStub; |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // try{ |
| // ccpsStub = new BACoordinatorCompletionParticipantServiceStub(((cancelingParticipant.getEpr()).toString())); |
| // Complete completeParam = new Complete(); |
| // ccpsStub.CompleteOperation(completeParam); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_COMPLETING); |
| // cancelingParticipant.setStatus(BACoordinatorStatus.STATUS_COMPLETING); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in cancelling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETING: |
| // try{ |
| // ccpsStub = new BACoordinatorCompletionParticipantServiceStub(((cancelingParticipant.getEpr()).toString())); |
| // Complete completeParam = new Complete(); |
| // ccpsStub.CompleteOperation(completeParam); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_COMPLETING); |
| // cancelingParticipant.setStatus(BACoordinatorStatus.STATUS_COMPLETING); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in ended state"); |
| // } |
| //} |
| ////End - Complete |
| // |
| ////Start - Close |
| //public void CCCloseOperation(BAActivityContext baContext,String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAParticipantInformation baParticipantInformation = baContext.getParticipant(enlishmentID); |
| // baContext.lock(); |
| // BACoordinatorCompletionParticipantServiceStub ccpsStub; |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in cancelling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // try{ |
| // String participantEndpointReference = baParticipantInformation.getEpr().toString(); |
| // ccpsStub = new BACoordinatorCompletionParticipantServiceStub(participantEndpointReference); |
| // Close closeParam = new Close(); |
| // ccpsStub.CloseOperation(closeParam); |
| // baParticipantInformation.setStatus(BACoordinatorStatus.STATUS_CLOSING); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // try{ |
| // |
| // String participantEndpointReference = baParticipantInformation.getEpr().toString(); |
| // ccpsStub = new BACoordinatorCompletionParticipantServiceStub(participantEndpointReference); |
| // Close closeParam = new Close(); |
| // ccpsStub.CloseOperation(closeParam); |
| // baParticipantInformation.setStatus(BACoordinatorStatus.STATUS_CLOSING); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // } |
| //} |
| ////End - Close |
| // |
| ////Start - Compensate |
| //public void CCCompensateOperation(BAActivityContext baContext,String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BAParticipantInformation baParticipantInformation = baContext.getParticipant(enlishmentID); |
| // baContext.lock(); |
| // BACoordinatorCompletionParticipantServiceStub ccpsStub; |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in cancelling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // try{ |
| // String participantEndpointReference = baParticipantInformation.getEpr().toString(); |
| // ccpsStub = new BACoordinatorCompletionParticipantServiceStub(participantEndpointReference); |
| // Compensate compensateParam = new Compensate(); |
| // ccpsStub.CompensateOperation(compensateParam); |
| // baParticipantInformation.setStatus(BACoordinatorStatus.STATUS_COMPENSATING); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in cancelling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // try{ |
| // String participantEndpointReference = baParticipantInformation.getEpr().toString(); |
| // ccpsStub = new BACoordinatorCompletionParticipantServiceStub(participantEndpointReference); |
| // Compensate compensateParam = new Compensate(); |
| // ccpsStub.CompensateOperation(compensateParam); |
| // baParticipantInformation.setStatus(BACoordinatorStatus.STATUS_COMPENSATING); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // } |
| //} |
| ////End - compensate |
| ////Start -Failed |
| //public void CCFaultedOperation(BAActivityContext baContext, String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // baContext.lock(); |
| // BAParticipantInformation baParticipantInformation = baContext.getParticipant(enlishmentID); |
| // BACoordinatorCompletionParticipantServiceStub ccpsStub; |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in cancelling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING: |
| // try{ |
| // String participantEndpointReference = baParticipantInformation.getEpr().toString(); |
| // ccpsStub = new BACoordinatorCompletionParticipantServiceStub(participantEndpointReference); |
| // Failed failedParam = new Failed(); |
| // ccpsStub.FailedOperation(failedParam); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_ENDED); |
| // baParticipantInformation.setStatus(Status.BACoordinatorStatus.STATUS_ENDED); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in exiting state"); |
| // |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // try{ |
| // String participantEndpointReference = baParticipantInformation.getEpr().toString(); |
| // ccpsStub = new BACoordinatorCompletionParticipantServiceStub(participantEndpointReference); |
| // Failed failedParam = new Failed(); |
| // ccpsStub.FailedOperation(failedParam); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // } |
| // |
| //} |
| ////End - Failed |
| ////Start - Exited |
| //public void CCExitedOperation(AbstractContext context,String enlishmentID) |
| //throws AbstractKandulaException |
| //{ |
| // BACoordinatorCompletionParticipantServiceStub ccpsStub; |
| // BAActivityContext baContext = (BAActivityContext) context; |
| // baContext.lock(); |
| // BAParticipantInformation exitingParticipant = baContext.getParticipant(enlishmentID); |
| // |
| // switch(baContext.getStatus()) |
| // { |
| // case BACoordinatorStatus.STATUS_ACTIVE: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in active state"); |
| // |
| // case BACoordinatorStatus.STATUS_CANCELLING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in canceling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in canceling state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPLETED: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in completed state"); |
| // |
| // case BACoordinatorStatus.STATUS_CLOSING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in closing state"); |
| // |
| // case BACoordinatorStatus.STATUS_COMPENSATING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in compensating state"); |
| // |
| // case BACoordinatorStatus.STATUS_FAULTING: |
| // baContext.unlock(); |
| // throw new InvalidStateException( |
| // "Coordinator is in faulting state"); |
| // |
| // case BACoordinatorStatus.STATUS_EXITING: |
| // try{ |
| // ccpsStub = new BACoordinatorCompletionParticipantServiceStub(((exitingParticipant.getEpr()).toString())); |
| // Exited exitedParam = new Exited(); |
| // ccpsStub.ExitedOperation(exitedParam); |
| // exitingParticipant.setStatus(Status.BACoordinatorStatus.STATUS_ENDED); |
| // baContext.setStatus(BACoordinatorStatus.STATUS_ENDED); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| // case BACoordinatorStatus.STATUS_ENDED: |
| // try{ |
| // ccpsStub = new BACoordinatorCompletionParticipantServiceStub(((exitingParticipant.getEpr()).toString())); |
| // Exited exitedParam = new Exited(); |
| // ccpsStub.ExitedOperation(exitedParam); |
| // baContext.setStatus(Status.BACoordinatorStatus.STATUS_ENDED); |
| // baContext.unlock(); |
| // } |
| // catch(AxisFault e) |
| // { |
| // throw new KandulaGeneralException(e); |
| // } |
| // catch(Exception e) |
| // { |
| // //TODO |
| // } |
| } |
| |
| } |
| //End - Exited |
| |
| |
| |
| |
| } |
