Package com.swiftmq.impl.store.standard.transaction

Class TransactionManager

java.lang.Object
com.swiftmq.impl.store.standard.transaction.TransactionManager
All Implemented Interfaces:
CheckPointHandler
public class TransactionManager extends Object implements CheckPointHandler

  • Constructor Details

    • TransactionManager

      public TransactionManager(StoreContext ctx)

  • Method Details

    • getTxidCount

      public long getTxidCount()

    • getActiveTransactions

      public int getActiveTransactions()

    • isCheckPointInProgress

      public boolean isCheckPointInProgress()

    • lockForCheckPoint

      public void lockForCheckPoint()
      Specified by:
      lockForCheckPoint in interface CheckPointHandler

    • performCheckPoint

      public void performCheckPoint()
      Specified by:
      performCheckPoint in interface CheckPointHandler

    • checkPointDone

      public void checkPointDone()
      Specified by:
      checkPointDone in interface CheckPointHandler

    • initiateCheckPoint

      public void initiateCheckPoint(CheckPointFinishedListener finishedListener)

    • createTxId

      public long createTxId()

    • createTxId

      public long createTxId(boolean doWait)

    • removeTxId

      public void removeTxId(long txId)

    • toString

      public String toString()
      Overrides:
      toString in class Object