Package | Description |
---|---|
org.apache.sling.distribution.journal.impl.queue | |
org.apache.sling.distribution.journal.impl.queue.impl |
Modifier and Type | Method and Description |
---|---|
OffsetQueue<T> |
OffsetQueue.getMinOffsetQueue(long minOffset)
Return an
OffsetQueue offset queue which
contains all the items from the current queue at
an offset greater or equal to #minOffset. |
Modifier and Type | Method and Description |
---|---|
void |
OffsetQueue.putItems(OffsetQueue<T> offsetQueue)
Put all the items from the #offsetQueue in this queue.
|
Modifier and Type | Class and Description |
---|---|
class |
OffsetQueueImpl<T> |
Modifier and Type | Method and Description |
---|---|
OffsetQueue<T> |
OffsetQueueImpl.getMinOffsetQueue(long minOffset) |
OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> |
PubQueueCacheService.getOffsetQueue(String pubAgentName,
long minOffset) |
OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> |
PubQueueCache.getOffsetQueue(String pubAgentName,
long minOffset) |
Modifier and Type | Method and Description |
---|---|
void |
OffsetQueueImpl.putItems(OffsetQueue<T> offsetQueue) |
Constructor and Description |
---|
PubErrQueue(String queueName,
OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> agentQueue,
OffsetQueue<Long> errorQueue) |
PubErrQueue(String queueName,
OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> agentQueue,
OffsetQueue<Long> errorQueue) |
PubQueue(String queueName,
OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> offsetQueue,
int retries,
ClearCallback clearCallback) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.