Method Detail

• onProcessCreated

  void onProcessCreated​(ITXProcess process)

  Called when the process is created.

  Parameters:

  process - The process.

• getCoordinator

  ITXPCoordinator getCoordinator()

  Returns the coordinator

  Returns:

  the coordinator

• onMonitorAdded

  void onMonitorAdded​(ITXPMonitor monitor)

  Called when a monitor is added to the coordinator's monitor chain

  Parameters:

  monitor - the monitor that got added

• onMonitorRemoved

  void onMonitorRemoved​(ITXPMonitor monitor)

  Called when a monitor is removed from the coordinator's monitor chain

  Parameters:

  monitor - the monitor that got removed

• onBeganProcess

  void onBeganProcess​(ITXProcess process)

  Called when a process created and associated with he controller

  Parameters:

  process - the process

• onNodeAssociated

  void onNodeAssociated​(ITXProcess process,
                        ITXPNode node,
                        ITXPNode.State returnedState)

  Called when a node is associated with a process

  Parameters:

  process - the process

  node - the node

  returnedState - the returned node state

• onNodeDisassociated

  void onNodeDisassociated​(ITXProcess process,
                           ITXPNode node)

  Called when a node is disassociated from a process

  Parameters:

  process - the process

  node - the node

• onNodeReady

  void onNodeReady​(ITXProcess process,
                   ITXPNode node,
                   ITXPNode.State returnedState)

  Called when a node has finished doing the work needed

  Parameters:

  process - the process

  node - the node

  returnedState - the node state after attempting to do the work

• onNodeTimeoutSignaled

  void onNodeTimeoutSignaled​(ITXProcess process,
                             ITXPNode node)

  Called when a node indicates it timed out waiting on the process.

  Parameters:

  process - the process

  node - the node

• onProcessTimeoutSignaled

  void onProcessTimeoutSignaled​(ITXProcess process)

  Called when a process indicates it timed out waiting on the nodes

  Parameters:

  process - the process

• onCommitInitiated

  void onCommitInitiated​(ITXProcess process)

  Called when a process is called to attempt a commit

  Parameters:

  process - the process

• onCommitCanceled

  void onCommitCanceled​(ITXProcess process,
                        TXPException reason)

  Called when the process aborts committing. This can happen if a rollback is requested or one or more nodes have not yet finished processing.

  Parameters:

  process - the process

  reason - the exception thrown by the commit

• onRollbackInitiated

  void onRollbackInitiated​(ITXProcess process)

  Called when a process is called to attempt a rollback

  Parameters:

  process - the process

• onRollbackCanceled

  void onRollbackCanceled​(ITXProcess process,
                          TXPException reason)

  Called when the process aborts rolling back. This can happen if one or more nodes have not yet finished processing.

  Parameters:

  process - the process

  reason - the exception thrown by the rollback

• onNodeReadyFailedPolicyAction

  void onNodeReadyFailedPolicyAction​(ITXProcess process,
                                     ITXPNode node,
                                     ITXPPolicy.Action action)

  Called when the policy action is determined for a node that failed processing

  Parameters:

  process - the process

  node - the node

  action - the policy action

• onNodeCommitFailedPolicyAction

  void onNodeCommitFailedPolicyAction​(ITXProcess process,
                                      ITXPNode node,
                                      ITXPPolicy.Action action)

  Called when the policy action is determined for a node that failed to commit

  Parameters:

  process - the process

  node - the node

  action - the action

• onNodeRollbackFailedPolicyAction

  void onNodeRollbackFailedPolicyAction​(ITXProcess process,
                                        ITXPNode node,
                                        ITXPPolicy.Action action)

  Called when the policy action is determined for a node that failed to rollback

  Parameters:

  process - the process

  node - the node

  action - the action

• onNodeTimeoutSignaledPolicyAction

  void onNodeTimeoutSignaledPolicyAction​(ITXProcess process,
                                         ITXPNode node,
                                         ITXPPolicy.Action action)

  Called when the policy action is determined for a node that timed out waiting for completion.

  Parameters:

  process - the process

  node - the node

  action - the action

• onProcessTimeoutSignaledPolicyAction

  void onProcessTimeoutSignaledPolicyAction​(ITXProcess process,
                                            ITXPPolicy.Action action)

  Called when the policy action is determined for a process that timed out waiting for the nodes to do the work.

  Parameters:

  process - the process

  action - the action

• onProcessCompleted

  void onProcessCompleted​(ITXProcess process)

  Called when a process has been completed (either committed or rolled back)

  Parameters:

  process - The process.