Class SimpleDistributionQueueProvider

  • All Implemented Interfaces:
    org.apache.sling.distribution.queue.impl.DistributionQueueProvider

    public class SimpleDistributionQueueProvider
    extends Object
    implements org.apache.sling.distribution.queue.impl.DistributionQueueProvider
    a queue provider DistributionQueueProvider for simple in memory DistributionQueues
    • Constructor Detail

      • SimpleDistributionQueueProvider

        public SimpleDistributionQueueProvider​(org.apache.sling.commons.scheduler.Scheduler scheduler,
                                               String name,
                                               boolean checkpoint)
    • Method Detail

      • getQueue

        @NotNull
        public @NotNull DistributionQueue getQueue​(@NotNull
                                                   @NotNull String queueName)
        Description copied from interface: org.apache.sling.distribution.queue.impl.DistributionQueueProvider
        provide an DistributionQueueType.ORDERED queue with the given name
        Specified by:
        getQueue in interface org.apache.sling.distribution.queue.impl.DistributionQueueProvider
        Parameters:
        queueName - the name of the queue to retrieve
        Returns:
        a DistributionQueue
      • getQueue

        public DistributionQueue getQueue​(@NotNull
                                          @NotNull String queueName,
                                          @NotNull
                                          @NotNull DistributionQueueType type)
        Description copied from interface: org.apache.sling.distribution.queue.impl.DistributionQueueProvider
        provde a queue of the given type with the given name
        Specified by:
        getQueue in interface org.apache.sling.distribution.queue.impl.DistributionQueueProvider
        Parameters:
        queueName - the name of the queue
        type - the type of the queue
        Returns:
        a DistributionQueue
      • enableQueueProcessing

        public void enableQueueProcessing​(@NotNull
                                          @NotNull org.apache.sling.distribution.queue.impl.DistributionQueueProcessor queueProcessor,
                                          String... queueNames)
        Description copied from interface: org.apache.sling.distribution.queue.impl.DistributionQueueProvider
        enables queue processing
        Specified by:
        enableQueueProcessing in interface org.apache.sling.distribution.queue.impl.DistributionQueueProvider
        Parameters:
        queueProcessor - the queue processor to be used
      • disableQueueProcessing

        public void disableQueueProcessing()
        Description copied from interface: org.apache.sling.distribution.queue.impl.DistributionQueueProvider
        disables queue processing
        Specified by:
        disableQueueProcessing in interface org.apache.sling.distribution.queue.impl.DistributionQueueProvider