-
Method Summary
int
Get maximum size of all queues for a pubAgentName
OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem>
org.apache.sling.distribution.queue.spi.DistributionQueue
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 Details
-
getQueue
@Nullable
org.apache.sling.distribution.queue.spi.DistributionQueue getQueue(String pubAgentName,
String queueName)
-
getMaxQueueSize
int getMaxQueueSize(String pubAgentName)
Get maximum size of all queues for a pubAgentName
- Parameters:
pubAgentName
- name of the pub agent
- Returns:
- max size of all queues or 0 if there are none
-
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
Get queue names for alive subscribed subscriber agents.
-