| Methods Summary |
|---|
| public void | abortedOperation(Notification parameters)
final String METHOD_NAME = "abortedOperation";
initContextFromIncomingMessage();
if (logger.isLogging(Level.FINER)) {
logger.entering(METHOD_NAME, getCoordIdPartId());
}
if (coordinator != null) {
coordinator.aborted(participantId);
} else {
if (logger.isLogging(Level.SEVERE)) {
logger.severe("abortedOperation", "unknown coordId or partId " + getCoordIdPartId());
}
}
if (logger.isLogging(Level.FINER)) {
logger.exiting(METHOD_NAME, getCoordIdPartId());
}
|
| public void | committedOperation(Notification parameters)
final String METHOD_NAME = "committedOperation";
initContextFromIncomingMessage();
if (logger.isLogging(Level.FINER)) {
logger.entering(METHOD_NAME, getCoordIdPartId());
}
if (coordinator != null) {
coordinator.committed(participantId);
} else {
// TODO unknown activity id, is logging enough or send something to participant fallbackEPR
if (logger.isLogging(Level.SEVERE)) {
logger.severe("committedOperation", "unknown coordId or partId " + getCoordIdPartId());
}
}
if (logger.isLogging(Level.FINER)) {
logger.exiting(METHOD_NAME, getCoordIdPartId());
}
|
| private java.lang.String | getCoordIdPartId()
return "CoorId=" + activityId + " PartId=" + participantId + " ";
|
| public static com.sun.xml.ws.developer.StatefulWebServiceManager | getManager()
return manager;
|
| private void | initContextFromIncomingMessage()
coordinator = (ATCoordinator) CoordinationManager.getInstance().getCoordinator(activityId);
if (wsContext != null) {
MessageContext mc = wsContext.getMessageContext();
//TODO start using replyTo EPR if coordinator/participant is unknown or if initial remote 2PC notification
// fails one should see if replyTo EPR can get notfication through.
HeaderList hdrLst = (HeaderList) mc.get(INBOUND_HEADER_LIST_PROPERTY);
if (hdrLst != null) {
fallbackEPR = hdrLst.getReplyTo(AddressingVersion.MEMBER, SOAPVersion.SOAP_11).toSpec(MemberSubmissionEndpointReference.class);
}
} else {
if (logger.isLogging(Level.WARNING)) {
logger.warning("initContextFromIncomingMessage", "wsContext unexpectedly null");
}
}
if (activityId == UNKNOWN_ID) {
if (logger.isLogging(Level.INFO)) {
logger.info("Atomic Transaction Coordinator", "handling notification for an unknown transaction");
}
coordinator = null;
} else {
coordinator = (ATCoordinator) CoordinationManager.getInstance().getCoordinator(activityId);
}
|
| public void | preparedOperation(Notification parameters)
final String METHOD_NAME = "preparedOperation";
initContextFromIncomingMessage();
if (logger.isLogging(Level.FINER)) {
logger.entering(METHOD_NAME, getCoordIdPartId());
}
if (coordinator != null) {
coordinator.prepared(participantId);
} else {
// TODO unknown activity id, send rollbackOperation to participant
if (logger.isLogging(Level.SEVERE)) {
logger.severe("preparedOperation", "unknown coordId or partId " + getCoordIdPartId());
}
}
if (logger.isLogging(Level.FINER)) {
logger.exiting(METHOD_NAME, getCoordIdPartId());
}
|
| public void | readOnlyOperation(Notification parameters)
final String METHOD_NAME = "readonlyOperation";
initContextFromIncomingMessage();
if (logger.isLogging(Level.FINER)) {
logger.entering(METHOD_NAME, getCoordIdPartId());
}
if (coordinator != null) {
coordinator.readonly(participantId);
} else {
// TODO unknown activity id, is logging enough or send something to fallback EPR
if (logger.isLogging(Level.SEVERE)) {
logger.severe("readonlyOperation", "unknown coordId or partId " + getCoordIdPartId());
}
}
if (logger.isLogging(Level.FINER)) {
logger.exiting(METHOD_NAME, getCoordIdPartId());
}
|
| public void | replayOperation(Notification parameters)
final String METHOD_NAME = "replayOperation";
initContextFromIncomingMessage();
if (logger.isLogging(Level.FINER)) {
logger.entering(METHOD_NAME, getCoordIdPartId());
}
if (coordinator != null) {
coordinator.replay(participantId);
} else {
// TODO unknown activity id, is logging enough or send something to participant fallbackEPR
if (logger.isLogging(Level.SEVERE)) {
logger.severe("replayOperation", "unknown coordId or partId " + getCoordIdPartId());
}
}
if (logger.isLogging(Level.FINER)) {
logger.exiting(METHOD_NAME, getCoordIdPartId());
}
|
| public static void | setManager(com.sun.xml.ws.developer.StatefulWebServiceManager aManager)
manager = aManager;
|
