public void commitActivity()

in src/org/apache/kandula/coordinator/at/ATCoordinator.java [342:366]

22 lines of code
4 McCabe index (conditional complexity)


	public void commitActivity(AbstractContext context)
			throws AbstractKandulaException {

		ATActivityContext atContext = (ATActivityContext) context;

		atContext.lock();
		atContext.setStatus(Status.CoordinatorStatus.STATUS_COMMITTING);
		atContext.unlock();
		Iterator participants = atContext.getAll2PCParticipants();
		if (participants.hasNext()) {
			// check whether all participants have prepared
			ParticipantPortTypeRawXMLStub stub = new ParticipantPortTypeRawXMLStub();
			while (participants.hasNext()) {
				ATParticipantInformation participant = (ATParticipantInformation) participants
						.next();
				if (!(Status.CoordinatorStatus.STATUS_READ_ONLY == participant
						.getStatus())) {
					stub.commitOperation(participant.getEpr());
				}
			}
		}
		CompletionInitiatorPortTypeRawXMLStub completionStub = new CompletionInitiatorPortTypeRawXMLStub(
				atContext.getCompletionParticipant());
		completionStub.committedOperation();
	}