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

Class PageSubscriptionImpl.PageCursorInfo

java.lang.Object
org.apache.activemq.artemis.core.paging.cursor.impl.PageSubscriptionImpl.PageCursorInfo
All Implemented Interfaces:
ConsumedPage
Enclosing class:
PageSubscriptionImpl
public final class PageSubscriptionImpl.PageCursorInfo extends Object implements ConsumedPage
This will hold information about the pending ACKs towards a page.

This instance will be released as soon as the entire page is consumed, releasing the memory at that point The ref counts are increased also when a message is ignored for any reason.

  • Method Details

    • isAck

      public boolean isAck(int messageNumber)
      Specified by:
      isAck in interface ConsumedPage

    • forEachAck

      public void forEachAck(BiConsumer<Integer,PagePosition> ackConsumer)
      Specified by:
      forEachAck in interface ConsumedPage

    • getAcks

      public io.netty.util.collection.IntObjectHashMap getAcks()

    • getRemovedReferences

      public io.netty.util.collection.IntObjectHashMap getRemovedReferences()

    • getCompletePageInformation

      public PagePosition getCompletePageInformation()

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • clear

      public void clear()

    • setCompleteInfo

      public void setCompleteInfo(PagePosition completePage)

    • getCompleteInfo

      public PagePosition getCompleteInfo()

    • isDone

      public boolean isDone()
      Specified by:
      isDone in interface ConsumedPage

    • isPendingDelete

      public boolean isPendingDelete()

    • setPendingDelete

      public void setPendingDelete()

    • getPageId

      public long getPageId()
      Specified by:
      getPageId in interface ConsumedPage

    • incrementPendingTX

      public void incrementPendingTX()

    • decrementPendingTX

      public void decrementPendingTX()

    • isRemoved

      public boolean isRemoved(int messageNr)

    • remove

      public void remove(int messageNr)

    • addACK

      public void addACK(PagePosition posACK)

    • loadACK

      public void loadACK(PagePosition posACK)

    • checkDone

      protected void checkDone()

    • getPendingTx

      public int getPendingTx()