Class JobHandlingDistributionQueueProvider
- java.lang.Object
-
- org.apache.sling.distribution.queue.impl.jobhandling.JobHandlingDistributionQueueProvider
-
- All Implemented Interfaces:
org.apache.sling.distribution.queue.impl.DistributionQueueProvider
public class JobHandlingDistributionQueueProvider extends Object implements org.apache.sling.distribution.queue.impl.DistributionQueueProvider
a queue providerDistributionQueueProviderfor sling jobs basedDistributionQueues
-
-
Constructor Summary
Constructors Constructor Description JobHandlingDistributionQueueProvider(String prefix, org.apache.sling.event.jobs.JobManager jobManager, org.osgi.framework.BundleContext context)JobHandlingDistributionQueueProvider(String prefix, org.apache.sling.event.jobs.JobManager jobManager, org.osgi.framework.BundleContext context, org.osgi.service.cm.ConfigurationAdmin configAdmin)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voiddisableQueueProcessing()disables queue processingvoidenableQueueProcessing(@NotNull org.apache.sling.distribution.queue.impl.DistributionQueueProcessor queueProcessor, String... queueNames)enables queue processing@NotNull DistributionQueuegetQueue(@NotNull String queueName)provide anDistributionQueueType.ORDEREDqueue with the given nameDistributionQueuegetQueue(@NotNull String queueName, @NotNull DistributionQueueType type)provde a queue of the given type with the given name
-
-
-
Field Detail
-
TYPE
public static final String TYPE
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
JobHandlingDistributionQueueProvider
public JobHandlingDistributionQueueProvider(String prefix, org.apache.sling.event.jobs.JobManager jobManager, org.osgi.framework.BundleContext context)
-
JobHandlingDistributionQueueProvider
public JobHandlingDistributionQueueProvider(String prefix, org.apache.sling.event.jobs.JobManager jobManager, org.osgi.framework.BundleContext context, org.osgi.service.cm.ConfigurationAdmin configAdmin)
-
-
Method Detail
-
getQueue
@NotNull public @NotNull DistributionQueue getQueue(@NotNull @NotNull String queueName)
Description copied from interface:org.apache.sling.distribution.queue.impl.DistributionQueueProviderprovide anDistributionQueueType.ORDEREDqueue with the given name- Specified by:
getQueuein interfaceorg.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.DistributionQueueProviderprovde a queue of the given type with the given name- Specified by:
getQueuein interfaceorg.apache.sling.distribution.queue.impl.DistributionQueueProvider- Parameters:
queueName- the name of the queuetype- 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 DistributionExceptionDescription copied from interface:org.apache.sling.distribution.queue.impl.DistributionQueueProviderenables queue processing- Specified by:
enableQueueProcessingin interfaceorg.apache.sling.distribution.queue.impl.DistributionQueueProvider- Parameters:
queueProcessor- the queue processor to be used- Throws:
DistributionException
-
disableQueueProcessing
public void disableQueueProcessing()
Description copied from interface:org.apache.sling.distribution.queue.impl.DistributionQueueProviderdisables queue processing- Specified by:
disableQueueProcessingin interfaceorg.apache.sling.distribution.queue.impl.DistributionQueueProvider
-
-