Interface PubQueueProvider

All Superinterfaces:
AutoCloseable, Closeable

@ParametersAreNonnullByDefault public interface PubQueueProvider extends Closeable
  • Method Details

    • getQueue

      @Nullable org.apache.sling.distribution.queue.spi.DistributionQueue getQueue(String pubAgentName, String queueName)
    • getMaxQueueSize

      int getMaxQueueSize(String pubAgentName)
      Get maximum size of all queues for a pubAgentName
      Parameters:
      pubAgentName - name of the pub agent
      Returns:
      max size of all queues or 0 if there are none
    • getOffsetQueue

      @Nonnull OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> getOffsetQueue(String pubAgentName, long minOffset)
    • handleStatus

      void handleStatus(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.PackageStatusMessage message)
    • getQueueNames

      Set<String> getQueueNames(String pubAgentName)
      Get queue names for alive subscribed subscriber agents.
    • getQueuedNotifier

      @Nonnull PackageQueuedNotifier getQueuedNotifier()