@ParametersAreNonnullByDefault public class PubQueueCache extends Object
Constructor and Description |
---|
PubQueueCache(org.apache.sling.distribution.journal.MessagingProvider messagingProvider,
org.osgi.service.event.EventAdmin eventAdmin,
DistributionMetricsService distributionMetricsService,
String topic) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected long |
getMinOffset() |
OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> |
getOffsetQueue(String pubAgentName,
long minOffset) |
int |
size() |
public PubQueueCache(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, org.osgi.service.event.EventAdmin eventAdmin, DistributionMetricsService distributionMetricsService, String topic)
@Nonnull public OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> getOffsetQueue(String pubAgentName, long minOffset) throws InterruptedException
InterruptedException
public int size()
public void close()
protected long getMinOffset()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.