public class JobHandlingDistributionQueueProvider extends Object implements DistributionQueueProvider
DistributionQueueProvider
for sling jobs based
DistributionQueue
sConstructor and Description |
---|
JobHandlingDistributionQueueProvider(String name,
org.apache.sling.event.jobs.JobManager jobManager,
org.osgi.framework.BundleContext context) |
Modifier and Type | Method and Description |
---|---|
void |
disableQueueProcessing()
disables queue processing
|
void |
enableQueueProcessing(DistributionQueueProcessor queueProcessor,
String... queueNames)
enables queue processing
|
DistributionQueue |
getQueue(String queueName)
provide a named queue for the given agent
|
public JobHandlingDistributionQueueProvider(String name, org.apache.sling.event.jobs.JobManager jobManager, org.osgi.framework.BundleContext context)
@Nonnull public DistributionQueue getQueue(@Nonnull String queueName)
DistributionQueueProvider
getQueue
in interface DistributionQueueProvider
queueName
- the name of the queue to retrieveDistributionQueue
public void enableQueueProcessing(@Nonnull 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–2016 The Apache Software Foundation. All rights reserved.