@ParametersAreNonnullByDefault public class PubQueueCacheService extends Object implements Runnable
Constructor and Description |
---|
PubQueueCacheService() |
PubQueueCacheService(org.apache.sling.distribution.journal.MessagingProvider messagingProvider,
Topics topics,
org.osgi.service.event.EventAdmin eventAdmin) |
Modifier and Type | Method and Description |
---|---|
void |
activate() |
void |
deactivate() |
OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> |
getOffsetQueue(String pubAgentName,
long minOffset) |
void |
run() |
public PubQueueCacheService()
public PubQueueCacheService(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, Topics topics, org.osgi.service.event.EventAdmin eventAdmin)
public void activate()
public void deactivate()
public OffsetQueue<org.apache.sling.distribution.queue.DistributionQueueItem> getOffsetQueue(String pubAgentName, long minOffset)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.