in src/org/apache/kandula/coordinator/at/ATSubCoordinator.java [28:49]
public EndpointReference addParticipant(AbstractContext context,
String protocol, EndpointReference participantEPR)
throws AbstractKandulaException {
ATActivityContext atContext = (ATActivityContext) context;
if (protocol.equals(Constants.WS_AT_DURABLE2PC)) {
if (!atContext.getSubDurableRegistered()) {
// have to register with the parent coordinator
atContext.setSubDurableRegistered(true);
}
return atContext.addParticipant(participantEPR, protocol,null);
}
else if (protocol.equals(Constants.WS_AT_VOLATILE2PC)) {
if (!atContext.getSubDurableRegistered()) {
// have to register with the parent coordinator
atContext.setSubDurableRegistered(true);
}
//FIXME null
return atContext.addParticipant(participantEPR, protocol,null);
} else
throw new InvalidProtocolException();
}