Class ResourceQueueProvider

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

    public class ResourceQueueProvider
    extends Object
    implements org.apache.sling.distribution.queue.impl.DistributionQueueProvider
    • Constructor Detail

      • ResourceQueueProvider

        public ResourceQueueProvider​(org.osgi.framework.BundleContext context,
                                     org.apache.sling.api.resource.ResourceResolverFactory resolverFactory,
                                     String serviceName,
                                     String agentName,
                                     org.apache.sling.commons.scheduler.Scheduler scheduler,
                                     boolean isActive)
    • Method Detail

      • getQueue

        @NotNull
        public @NotNull 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)
                                   throws DistributionException
        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
        Throws:
        DistributionException
      • disableQueueProcessing

        public void disableQueueProcessing()
                                    throws DistributionException
        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
        Throws:
        DistributionException
      • close

        public void close()