Package org.apache.activemq.artemis.core.paging

Interface PageTransactionInfo

All Superinterfaces:
EncodingSupport
All Known Implementing Classes:
PageTransactionInfoImpl
public interface PageTransactionInfo extends EncodingSupport

  • Method Details

    • isCommit

      boolean isCommit()

    • isRollback

      boolean isRollback()

    • setCommitted

      void setCommitted(boolean committed)

    • reloadPrepared

      void reloadPrepared(Transaction transaction)

    • getPreparedTransaction

      Transaction getPreparedTransaction()

    • commit

      void commit()

    • rollback

      void rollback()

    • getRecordID

      long getRecordID()

    • setRecordID

      void setRecordID(long id)

    • getTransactionID

      long getTransactionID()

    • store

      void store(StorageManager storageManager, PagingManager pagingManager, Transaction tx) throws Exception
      Throws:
      Exception

    • storeUpdate

      void storeUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx) throws Exception
      Throws:
      Exception

    • reloadUpdate

      void reloadUpdate(StorageManager storageManager, PagingManager pagingManager, Transaction tx, int increment) throws Exception
      Throws:
      Exception

    • onUpdate

      boolean onUpdate(int update, StorageManager storageManager, PagingManager pagingManager)

    • checkSize

      boolean checkSize(StorageManager storageManager, PagingManager pagingManager)

    • increment

      void increment(int durableSize, int nonDurableSize)

    • getNumberOfMessages

      int getNumberOfMessages()

    • deliverAfterCommit

      boolean deliverAfterCommit(PageIterator pageIterator, PageSubscription cursor, PagedReference pagedMessage)
      This method will hold the position to be delivered later in case this transaction is pending. If the tx is not pending, it will return false, so the caller can deliver it right away
      Returns:
      true if the message will be delivered later, false if it should be delivered right away

    • isOrphaned

      boolean isOrphaned()
      Used on PageRebuildManager to cleanup orphaned Page Transactions

    • setOrphaned

      PageTransactionInfo setOrphaned(boolean orphaned)