@ParametersAreNonnullByDefault public class PubErrQueue extends Object implements org.apache.sling.distribution.queue.spi.DistributionQueue
Constructor and Description |
---|
PubErrQueue(String queueName,
OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> agentQueue,
OffsetQueue<Long> errorQueue) |
Modifier and Type | Method and Description |
---|---|
org.apache.sling.distribution.queue.DistributionQueueEntry |
add(org.apache.sling.distribution.queue.DistributionQueueItem distributionQueueItem) |
Iterable<org.apache.sling.distribution.queue.DistributionQueueEntry> |
clear(int limit) |
Iterable<org.apache.sling.distribution.queue.DistributionQueueEntry> |
getEntries(int skip,
int limit) |
org.apache.sling.distribution.queue.DistributionQueueEntry |
getEntry(String entryId) |
org.apache.sling.distribution.queue.DistributionQueueEntry |
getHead() |
String |
getName() |
org.apache.sling.distribution.queue.DistributionQueueStatus |
getStatus() |
org.apache.sling.distribution.queue.DistributionQueueType |
getType() |
boolean |
hasCapability(String capability) |
Iterable<org.apache.sling.distribution.queue.DistributionQueueEntry> |
remove(Set<String> entryIds) |
org.apache.sling.distribution.queue.DistributionQueueEntry |
remove(String entryId) |
public PubErrQueue(String queueName, OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> agentQueue, OffsetQueue<Long> errorQueue)
@Nonnull public String getName()
getName
in interface org.apache.sling.distribution.queue.spi.DistributionQueue
public org.apache.sling.distribution.queue.DistributionQueueEntry add(@Nonnull org.apache.sling.distribution.queue.DistributionQueueItem distributionQueueItem)
add
in interface org.apache.sling.distribution.queue.spi.DistributionQueue
public org.apache.sling.distribution.queue.DistributionQueueEntry getHead()
getHead
in interface org.apache.sling.distribution.queue.spi.DistributionQueue
@Nonnull public Iterable<org.apache.sling.distribution.queue.DistributionQueueEntry> getEntries(int skip, int limit)
getEntries
in interface org.apache.sling.distribution.queue.spi.DistributionQueue
public org.apache.sling.distribution.queue.DistributionQueueEntry getEntry(@Nonnull String entryId)
getEntry
in interface org.apache.sling.distribution.queue.spi.DistributionQueue
public org.apache.sling.distribution.queue.DistributionQueueEntry remove(@Nonnull String entryId)
remove
in interface org.apache.sling.distribution.queue.spi.DistributionQueue
@Nonnull public Iterable<org.apache.sling.distribution.queue.DistributionQueueEntry> remove(Set<String> entryIds)
remove
in interface org.apache.sling.distribution.queue.spi.DistributionQueue
@Nonnull public Iterable<org.apache.sling.distribution.queue.DistributionQueueEntry> clear(int limit)
clear
in interface org.apache.sling.distribution.queue.spi.DistributionQueue
@Nonnull public org.apache.sling.distribution.queue.DistributionQueueStatus getStatus()
getStatus
in interface org.apache.sling.distribution.queue.spi.DistributionQueue
@Nonnull public org.apache.sling.distribution.queue.DistributionQueueType getType()
getType
in interface org.apache.sling.distribution.queue.spi.DistributionQueue
public boolean hasCapability(String capability)
hasCapability
in interface org.apache.sling.distribution.queue.spi.DistributionQueue
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.