in src/org/apache/kandula/participant/ba/BAParticipantTransactionSentCoordinator.java [144:177]
public void exit(ParticipantContext context) throws AbstractKandulaException {
BACoordinatorCompletionCoordinatorServiceStub coordinatorStub;
switch (context.getStatus()) {
case (Status.BAParticipantStatus.STATUS_ACTIVE):
case (Status.BAParticipantStatus.STATUS_COMPLETING):
case (Status.BAParticipantStatus.STATUS_EXITING):
try {
coordinatorStub = new BACoordinatorCompletionCoordinatorServiceStub(MessageContext
.getCurrentMessageContext().getConfigurationContext(), null);
coordinatorStub._getServiceClient().getOptions()
.setTo(context.getCoordinationEPR());
Exit exit = new Exit();
exit.setExit(new NotificationType());
context.setStatus(Status.BAParticipantStatus.STATUS_EXITING);
coordinatorStub.ExitOperation(exit);
} catch (Exception e) {
log.fatal("WS_BA : " + context.getCoordinationContext().getActivityID()
+ " : closed :" + context.getID() + " : " + e);
throw new KandulaGeneralException(e);
}
break;
case (Status.BAParticipantStatus.STATUS_CANCELLING):
case (Status.BAParticipantStatus.STATUS_COMPLETED):
case (Status.BAParticipantStatus.STATUS_CLOSING):
case (Status.BAParticipantStatus.STATUS_COMPENSATING):
case (Status.BAParticipantStatus.STATUS_FAULTING):
case (Status.BAParticipantStatus.STATUS_ENDED):
log.fatal("WS_BA : " + context.getCoordinationContext().getActivityID() + " : exit :"
+ context.getID() + " : " + " Participant is in" + context.getStatus()
+ " (invalid) state");
throw new InvalidStateException(" Participant is in" + context.getStatus()
+ " (invalid) state");
}
}