@ParametersAreNonnullByDefault public interface PubQueueProvider extends Closeable
Modifier and Type | Method and Description |
---|---|
OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> |
getOffsetQueue(String pubAgentName,
long minOffset) |
org.apache.sling.distribution.queue.spi.DistributionQueue |
getQueue(String pubAgentName,
String queueName) |
PackageQueuedNotifier |
getQueuedNotifier() |
Set<String> |
getQueueNames(String pubAgentName)
Get queue names for alive subscribed subscriber agents.
|
void |
handleStatus(org.apache.sling.distribution.journal.MessageInfo info,
org.apache.sling.distribution.journal.messages.PackageStatusMessage message) |
@Nullable org.apache.sling.distribution.queue.spi.DistributionQueue getQueue(String pubAgentName, String queueName)
@Nonnull OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> getOffsetQueue(String pubAgentName, long minOffset)
void handleStatus(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.PackageStatusMessage message)
Set<String> getQueueNames(String pubAgentName)
@Nonnull PackageQueuedNotifier getQueuedNotifier()
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.