@ParametersAreNonnullByDefault public class PubQueueProviderImpl extends Object implements PubQueueProvider
Constructor and Description |
---|
PubQueueProviderImpl() |
PubQueueProviderImpl(PubQueueCacheService pubQueueCacheService,
org.apache.sling.distribution.journal.MessagingProvider messagingProvider,
Topics topics) |
Modifier and Type | Method and Description |
---|---|
void |
activate() |
void |
deactivate() |
org.apache.sling.distribution.queue.spi.DistributionQueue |
getErrorQueue(String pubAgentName,
String subSlingId,
String subAgentName,
String queueName) |
org.apache.sling.distribution.queue.spi.DistributionQueue |
getQueue(String pubAgentName,
String subSlingId,
String subAgentName,
String queueName,
long minOffset,
int headRetries,
boolean editable) |
void |
handleStatus(org.apache.sling.distribution.journal.MessageInfo info,
org.apache.sling.distribution.journal.messages.Messages.PackageStatusMessage message) |
public PubQueueProviderImpl()
public PubQueueProviderImpl(PubQueueCacheService pubQueueCacheService, org.apache.sling.distribution.journal.MessagingProvider messagingProvider, Topics topics)
public void activate()
public void deactivate()
@Nonnull public org.apache.sling.distribution.queue.spi.DistributionQueue getQueue(String pubAgentName, String subSlingId, String subAgentName, String queueName, long minOffset, int headRetries, boolean editable)
getQueue
in interface PubQueueProvider
@Nonnull public org.apache.sling.distribution.queue.spi.DistributionQueue getErrorQueue(String pubAgentName, String subSlingId, String subAgentName, String queueName)
getErrorQueue
in interface PubQueueProvider
public void handleStatus(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.Messages.PackageStatusMessage message)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.