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