Class 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 Detail

      • setCompleteInfo

        public void setCompleteInfo​(PagePosition completePage)
        Parameters:
        completePage -
      • isPendingDelete

        public boolean isPendingDelete()
      • setPendingDelete

        public void setPendingDelete()
      • getPageId

        public long getPageId()
        Specified by:
        getPageId in interface ConsumedPage
        Returns:
        the pageId
      • incrementPendingTX

        public void incrementPendingTX()
      • decrementPendingTX

        public void decrementPendingTX()
      • isRemoved

        public boolean isRemoved​(PagePosition pos)
      • checkDone

        protected void checkDone()
      • getValidCache

        public PageCache getValidCache()
      • getCache

        public PageCache getCache()
        Returns:
        the cache
      • getPendingTx

        public int getPendingTx()