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

Interface PageCursorProvider

All Known Implementing Classes:
PageCursorProviderImpl
public interface PageCursorProvider
The provider of Cursor for a given Address

  • Method Details

    • newReference

      PagedReference newReference(PagedMessage msg, PageSubscription sub)

    • getSubscription

      PageSubscription getSubscription(long queueId)
      Parameters:
      queueId - The cursorID should be the same as the queueId associated for persistence

    • forEachSubscription

      void forEachSubscription(Consumer<PageSubscription> consumer)

    • createSubscription

      PageSubscription createSubscription(long queueId, Filter filter, boolean durable)

    • processReload

      void processReload() throws Exception
      Throws:
      Exception

    • stop

      void stop()

    • counterSnapshot

      void counterSnapshot()

    • flushExecutors

      void flushExecutors()

    • scheduleCleanup

      Future<Boolean> scheduleCleanup()

    • disableCleanup

      void disableCleanup()

    • resumeCleanup

      void resumeCleanup()

    • onPageModeCleared

      void onPageModeCleared()
      Cleanup stuff as paging mode is being cleared

    • close

      void close(PageSubscription pageCursorImpl)

    • checkClearPageLimit

      void checkClearPageLimit()

    • counterRebuildStarted

      void counterRebuildStarted()

    • counterRebuildDone

      void counterRebuildDone()

    • isRebuildDone

      boolean isRebuildDone()