in src/org/apache/kandula/participant/ba/ParticipantOutFaultHandler.java [22:44]
public InvocationResponse invoke(MessageContext msgContext) throws AxisFault {
Object property = msgContext.getOperationContext()
.getProperty(AbstractContext.REQUESTER_ID);
if (property != null) {
String reqID = (String) property;
AbstractContext context = StorageUtils.getContext(msgContext, reqID);
if (context != null) {
ParticipantContext participantContext = (ParticipantContext) context;
if (participantContext.getRegistrationProtocol().equals(Constants.WS_BA_CC)
|| participantContext.getRegistrationProtocol().equals(Constants.WS_BA_PC)) {
// Notify the coordinator if the participant is wsba-pc
BAParticipantTransactionSentCoordinator coordinator = new BAParticipantTransactionSentCoordinator();
try {
coordinator.fault(participantContext);
} catch (AbstractKandulaException e) {
throw AxisFault.makeFault(e);
}
}
}
}
return InvocationResponse.CONTINUE;
}