protected void compensateOperation()

in src/org/apache/kandula/coordinator/ba/BACoordinator.java [180:220]
41 lines of code
11 McCabe index (conditional complexity)

	protected void compensateOperation(BAActivityContext baContext, String enlistmentID)
			throws AbstractKandulaException {
		BAParticipantInformation baParticipantInformation = baContext.getParticipant(enlistmentID);
		BACoordinatorCompletionParticipantServiceStub participantServiceStub;
		switch (baParticipantInformation.getStatus()) {
		case BACoordinatorStatus.STATUS_ACTIVE:
		case BACoordinatorStatus.STATUS_CANCELLING:
		case BACoordinatorStatus.STATUS_CLOSING:
		case BACoordinatorStatus.STATUS_FAULTING:
		case BACoordinatorStatus.STATUS_EXITING:
		case BACoordinatorStatus.STATUS_ENDED:
		case BACoordinatorStatus.STATUS_COMPLETING:
			log.fatal("WS_BA : " + baContext.getCoordinationContext().getActivityID()
					+ " : compensateOperation : Coordinator is in" + baContext.getStatus()
					+ " (invalid) state");
			throw new InvalidStateException("Coordinator is in" + baContext.getStatus() + "state");
		case BACoordinatorStatus.STATUS_COMPLETED:
		case BACoordinatorStatus.STATUS_COMPENSATING:
			try {
				participantServiceStub = new BACoordinatorCompletionParticipantServiceStub(
						KandulaConfiguration.getInstance()
								.getCoordinatorAxis2ConfigurationContext(), null);
				participantServiceStub._getServiceClient().getOptions().setTo(
						baParticipantInformation.getEpr());
				Compensate compensate = new Compensate();
				compensate.setCompensate(new NotificationType());
				baParticipantInformation.setStatus(BACoordinatorStatus.STATUS_COMPENSATING);
				participantServiceStub.CompensateOperation(compensate);
			} catch (Exception e) {
				log.fatal("WS_BA : " + baContext.getCoordinationContext().getActivityID()
						+ " : compensateOperation :" + baParticipantInformation + " : " + e);
				throw new KandulaGeneralException(e);
			}
			break;
			default:
			log.fatal("WS_BA : " + baContext.getCoordinationContext().getActivityID()
					+ " : compensateOperation : Coordinator is in" + baContext.getStatus()
					+ " (invalid) state, Defaulting");
			throw new InvalidStateException("Coordinator is in" + baContext.getStatus() + "state");
		}
	}