public class JobHandlingDistributionQueueProvider extends Object implements DistributionQueueProvider
DistributionQueueProvider
for sling jobs based
DistributionQueue
sConstructor and 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) |
Modifier and Type | Method and Description |
---|---|
void |
disableQueueProcessing()
disables queue processing
|
void |
enableQueueProcessing(@NotNull DistributionQueueProcessor queueProcessor,
String... queueNames)
enables queue processing
|
@NotNull DistributionQueue |
getQueue(@NotNull String queueName)
provide an
DistributionQueueType.ORDERED queue with the given name |
DistributionQueue |
getQueue(@NotNull String queueName,
@NotNull DistributionQueueType type)
provde a queue of the given type with the given name
|
public static final String TYPE
public JobHandlingDistributionQueueProvider(String prefix, org.apache.sling.event.jobs.JobManager jobManager, org.osgi.framework.BundleContext context)
public JobHandlingDistributionQueueProvider(String prefix, org.apache.sling.event.jobs.JobManager jobManager, org.osgi.framework.BundleContext context, org.osgi.service.cm.ConfigurationAdmin configAdmin)
@NotNull public @NotNull DistributionQueue getQueue(@NotNull @NotNull String queueName)
DistributionQueueProvider
DistributionQueueType.ORDERED
queue with the given namegetQueue
in interface DistributionQueueProvider
queueName
- the name of the queue to retrieveDistributionQueue
public DistributionQueue getQueue(@NotNull @NotNull String queueName, @NotNull @NotNull DistributionQueueType type)
DistributionQueueProvider
getQueue
in interface DistributionQueueProvider
queueName
- the name of the queuetype
- the type of the queueDistributionQueue
public void enableQueueProcessing(@NotNull @NotNull DistributionQueueProcessor queueProcessor, String... queueNames) throws DistributionException
DistributionQueueProvider
enableQueueProcessing
in interface DistributionQueueProvider
queueProcessor
- the queue processor to be usedDistributionException
public void disableQueueProcessing()
DistributionQueueProvider
disableQueueProcessing
in interface DistributionQueueProvider
Copyright © 2007–2018 The Apache Software Foundation. All rights reserved.