com.cloudtran.jmx
Class AbstractCoordinatorShutDown

java.lang.Object
  extended by com.cloudtran.jmx.AbstractCoordinatorShutDown

public abstract class AbstractCoordinatorShutDown
extends Object

The purpose of this class to help to determine and report the status of the shut down of the coordinator. It checks various queues and if they are empty it checks the distributed transaction info objects in the space if they status is completed to space or not. Completed to space means: either ABORTED or COMMITTED & PERSISTED & LOGGED. The status of the shut down is logged in every 10 second.


Constructor Summary
AbstractCoordinatorShutDown()
           
 
Method Summary
abstract  boolean areCommitOrAbortQueuesEmpty()
           
abstract  void checkSpaceInfo()
           
abstract  String getCommitOrAbortQueueStatuses()
           
static CoordinatorShutDown getCoordinatorShutDown()
           
 String getLogQueueStatus()
           
 String getTimeoutEntryQueueStatus()
           
 String getTransactionIdsFromCollection(Collection<com.cloudtran.txb.TransactionInfoForPersistor> collection)
           
 String getTxAvailableToPersistQueueStatus()
           
static void setCoordinatorShutDown(CoordinatorShutDown csbh)
           
 void waitTillEverythingIsProcessed()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AbstractCoordinatorShutDown

public AbstractCoordinatorShutDown()
Method Detail

checkSpaceInfo

public abstract void checkSpaceInfo()

setCoordinatorShutDown

public static void setCoordinatorShutDown(CoordinatorShutDown csbh)

getCoordinatorShutDown

public static CoordinatorShutDown getCoordinatorShutDown()

waitTillEverythingIsProcessed

public void waitTillEverythingIsProcessed()

getTimeoutEntryQueueStatus

public String getTimeoutEntryQueueStatus()

getCommitOrAbortQueueStatuses

public abstract String getCommitOrAbortQueueStatuses()

getLogQueueStatus

public String getLogQueueStatus()

getTxAvailableToPersistQueueStatus

public String getTxAvailableToPersistQueueStatus()

getTransactionIdsFromCollection

public String getTransactionIdsFromCollection(Collection<com.cloudtran.txb.TransactionInfoForPersistor> collection)

areCommitOrAbortQueuesEmpty

public abstract boolean areCommitOrAbortQueuesEmpty()