Class MirrorTransaction

java.lang.Object
org.apache.activemq.artemis.core.transaction.impl.TransactionImpl
org.apache.activemq.artemis.protocol.amqp.connect.mirror.MirrorTransaction
All Implemented Interfaces:
org.apache.activemq.artemis.core.transaction.Transaction
public class MirrorTransaction extends org.apache.activemq.artemis.core.transaction.impl.TransactionImpl
MirrorTransaction disable some syncs in storage, and plays with OperationConsistencyLevel to relax some of the syncs required for Mirroring.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.activemq.artemis.core.transaction.Transaction

    org.apache.activemq.artemis.core.transaction.Transaction.State

  • Field Summary

    Fields inherited from class org.apache.activemq.artemis.core.transaction.impl.TransactionImpl

    containsPersistent, id, state, storageManager, xid

  • Constructor Summary

    Constructors
    Constructor
    Description
    MirrorTransaction(org.apache.activemq.artemis.core.persistence.StorageManager storageManager)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    afterCommit(List<org.apache.activemq.artemis.core.transaction.TransactionOperation> operationsToComplete)
     
    protected OperationConsistencyLevel
    getRequiredConsistency()
     
    boolean
    isAllowPageTransaction()
     
    MirrorTransaction
    setAllowPageTransaction(boolean allowPageTransaction)
     

    Methods inherited from class org.apache.activemq.artemis.core.transaction.impl.TransactionImpl

    addOperation, afterStore, afterWired, commit, commit, createRefsOperation, delay, delayDone, doCommit, doRollback, getAllOperations, getCreateTime, getID, getPendingDelay, getProperty, getProtocolData, getState, getXid, hasTimedOut, hasTimedOut, isAsync, isContainsPersistent, isEffective, markAsRollbackOnly, prepare, putProperty, resume, rollback, setAsync, setContainsPersistent, setProtocolData, setState, setTimeout, suspend, toString, tryRollback

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Constructor Details

    • MirrorTransaction

      public MirrorTransaction(org.apache.activemq.artemis.core.persistence.StorageManager storageManager)

  • Method Details

    • afterCommit

      protected void afterCommit(List<org.apache.activemq.artemis.core.transaction.TransactionOperation> operationsToComplete)
      Overrides:
      afterCommit in class org.apache.activemq.artemis.core.transaction.impl.TransactionImpl

    • isAllowPageTransaction

      public boolean isAllowPageTransaction()

    • setAllowPageTransaction

      public MirrorTransaction setAllowPageTransaction(boolean allowPageTransaction)

    • getRequiredConsistency

      protected OperationConsistencyLevel getRequiredConsistency()
      Overrides:
      getRequiredConsistency in class org.apache.activemq.artemis.core.transaction.impl.TransactionImpl