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

Interface ConsumedPage

All Known Implementing Classes:
PageSubscriptionImpl.PageCursorInfo
public interface ConsumedPage

  • Method Details

    • getPageId

      long getPageId()

    • isDone

      boolean isDone()

    • isAck

      boolean isAck(int messageNumber)

    • forEachAck

      void forEachAck(BiConsumer<Integer,PagePosition> ackConsumer)