public EndpointReference addParticipant()

in src/org/apache/kandula/context/impl/ATActivityContext.java [89:109]

21 lines of code
5 McCabe index (conditional complexity)


	public EndpointReference addParticipant(EndpointReference participantEPR,
			String protocol,String enlistmentID) throws AbstractKandulaException {
		 if (enlistmentID == null) {
			enlistmentID = EndpointReferenceFactory.getRandomStringOf18Characters();
		}
		if (Constants.WS_AT_VOLATILE2PC.equals(protocol)) {
			addVolatileParticipant(participantEPR, enlistmentID);
			return EndpointReferenceFactory.getInstance()
					.get2PCCoordinatorEndpoint(activityID, enlistmentID);
		} else if (Constants.WS_AT_DURABLE2PC.equals(protocol)) {
			addDurableParticipant(participantEPR, enlistmentID);
			return EndpointReferenceFactory.getInstance()
					.get2PCCoordinatorEndpoint(activityID, enlistmentID);
		} else if (Constants.WS_AT_COMPLETION.equals(protocol)) {
			completionParticipant = participantEPR;
			return EndpointReferenceFactory.getInstance()
					.getCompletionEndpoint(this.activityID);
		} else {
			throw new InvalidProtocolException();
		}
	}