Interface PubQueueProvider
-
- All Superinterfaces:
AutoCloseable
,Closeable
@ParametersAreNonnullByDefault public interface PubQueueProvider extends Closeable
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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)
-
-
-
Method Detail
-
getQueue
@Nullable org.apache.sling.distribution.queue.spi.DistributionQueue getQueue(String pubAgentName, String queueName)
-
getOffsetQueue
@Nonnull OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> getOffsetQueue(String pubAgentName, long minOffset)
-
handleStatus
void handleStatus(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.PackageStatusMessage message)
-
getQueueNames
Set<String> getQueueNames(String pubAgentName)
Get queue names for alive subscribed subscriber agents.
-
getQueuedNotifier
@Nonnull PackageQueuedNotifier getQueuedNotifier()
-
-