public class SimpleDistributionQueueProvider extends Object implements DistributionQueueProvider
DistributionQueueProvider
for simple in memory
DistributionQueue
sConstructor and Description |
---|
SimpleDistributionQueueProvider(org.apache.sling.commons.scheduler.Scheduler scheduler,
String name) |
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 SimpleDistributionQueueProvider(org.apache.sling.commons.scheduler.Scheduler scheduler, String name)
@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)
DistributionQueueProvider
enableQueueProcessing
in interface DistributionQueueProvider
queueProcessor
- the queue processor to be usedpublic void disableQueueProcessing()
DistributionQueueProvider
disableQueueProcessing
in interface DistributionQueueProvider
Copyright © 2007–2016 The Apache Software Foundation. All rights reserved.