Class SimpleDistributionQueueProvider
- java.lang.Object
-
- org.apache.sling.distribution.queue.impl.simple.SimpleDistributionQueueProvider
-
- All Implemented Interfaces:
org.apache.sling.distribution.queue.impl.DistributionQueueProvider
public class SimpleDistributionQueueProvider extends Object implements org.apache.sling.distribution.queue.impl.DistributionQueueProvider
a queue providerDistributionQueueProviderfor simple in memoryDistributionQueues
-
-
Field Summary
Fields Modifier and Type Field Description static StringTYPEstatic StringTYPE_CHECKPOINT
-
Constructor Summary
Constructors Constructor Description SimpleDistributionQueueProvider(org.apache.sling.commons.scheduler.Scheduler scheduler, String name, boolean checkpoint)
-
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
-
TYPE_CHECKPOINT
public static final String TYPE_CHECKPOINT
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
SimpleDistributionQueueProvider
public SimpleDistributionQueueProvider(org.apache.sling.commons.scheduler.Scheduler scheduler, String name, boolean checkpoint)
-
-
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)Description 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
-
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
-
-