public void compensatedOperation()

in src/org/apache/kandula/coordinator/ba/BACoordinator.java [222:258]
36 lines of code
16 McCabe index (conditional complexity)

	public void compensatedOperation(BAActivityContext baContext, String enlistmentID) throws AbstractKandulaException {
		BAParticipantInformation baPaticipantInformation = baContext.getParticipant(enlistmentID);
		switch (baPaticipantInformation.getStatus()) {
		case BACoordinatorStatus.STATUS_ACTIVE:
		case BACoordinatorStatus.STATUS_COMPLETED:
		case BACoordinatorStatus.STATUS_CLOSING:
		case BACoordinatorStatus.STATUS_FAULTING_COMPENSATING:
		case BACoordinatorStatus.STATUS_FAULTING_ACTIVE:
		case BACoordinatorStatus.STATUS_EXITING:
		case BACoordinatorStatus.STATUS_CANCELLING:
		case BACoordinatorStatus.STATUS_CANCELLING_ACTIVE:
		case BACoordinatorStatus.STATUS_CANCELLING_COMPLETING:
		case BACoordinatorStatus.STATUS_COMPLETING:
		case BACoordinatorStatus.STATUS_FAULTING_COMPLETING:
			log.fatal("WS_BA : " + baContext.getCoordinationContext().getActivityID()
					+ " : compensatedOperation : Coordinator is in" + baContext.getStatus()
					+ " (invalid) state");
			throw new InvalidStateException("Coordinator is in" + baContext.getStatus() + "state");

		case BACoordinatorStatus.STATUS_COMPENSATING:
			baPaticipantInformation.setStatus(BACoordinatorStatus.STATUS_ENDED);
			baContext.removeParticipant(baPaticipantInformation.getEnlistmentId());
			if ((baContext.getcoordinatorCompletionParticipantsCount() == 0)
					&& (baContext.getparticipantCompletionParticipantCount() == 0)) {
				baContext.setStatus(BACoordinatorStatus.STATUS_ENDED);
				StorageUtils.forgetContext(baContext.getCoordinationContext().getActivityID());
			}
			break;
		case BACoordinatorStatus.STATUS_ENDED:
			break;
		default:
			log.fatal("WS_BA : " + baContext.getCoordinationContext().getActivityID()
					+ " : compensatedOperation : Coordinator is in" + baContext.getStatus()
					+ " (invalid) state, Defaulting");
			throw new InvalidStateException("Coordinator is in" + baContext.getStatus() + "state");
		}
	}