public void volatilePrepare()

in src/org/apache/kandula/coordinator/at/ATCoordinator.java [378:403]

• 25 lines of code
• 4 McCabe index (conditional complexity)

	public void volatilePrepare(AbstractContext context)
			throws AbstractKandulaException {
		ParticipantPortTypeRawXMLStub stub = new ParticipantPortTypeRawXMLStub();
		ATActivityContext atContext = (ATActivityContext) context;
		Iterator volatilePartipantIterator = atContext
				.getRegistered2PCParticipants(Constants.WS_AT_VOLATILE2PC);
		synchronized (atContext) {
			if (volatilePartipantIterator.hasNext()) {
				while (volatilePartipantIterator.hasNext()) {
					atContext.incrementPreparingParticipantCount();
					stub
							.prepareOperation(((ATParticipantInformation) volatilePartipantIterator
									.next()).getEpr());
				}
			}
		}

		try {
			Method method = ATCoordinator.class.getMethod("durablePrepare",
					new Class[] { AbstractContext.class });
			atContext.setCallBackMethod(method);
		} catch (Exception e) {
			throw new KandulaGeneralException("Internal Kandula Server Error ",
					e);
		}
	}