public class MessagingCacheCallback extends Object implements CacheCallback
Constructor and Description |
---|
MessagingCacheCallback(org.apache.sling.distribution.journal.MessagingProvider messagingProvider,
String packageTopic,
DistributionMetricsService distributionMetricsService,
DiscoveryService discoveryService,
Consumer<org.apache.sling.distribution.journal.messages.ClearCommand> commandSender) |
Modifier and Type | Method and Description |
---|---|
Closeable |
createConsumer(org.apache.sling.distribution.journal.MessageHandler<org.apache.sling.distribution.journal.messages.PackageMessage> handler) |
List<org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.PackageMessage>> |
fetchRange(long minOffset,
long maxOffset) |
QueueState |
getQueueState(String pubAgentName,
String subAgentId) |
Set<String> |
getSubscribedAgentIds(String pubAgentName) |
public MessagingCacheCallback(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, String packageTopic, DistributionMetricsService distributionMetricsService, DiscoveryService discoveryService, Consumer<org.apache.sling.distribution.journal.messages.ClearCommand> commandSender)
public Closeable createConsumer(org.apache.sling.distribution.journal.MessageHandler<org.apache.sling.distribution.journal.messages.PackageMessage> handler)
createConsumer
in interface CacheCallback
public List<org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.PackageMessage>> fetchRange(long minOffset, long maxOffset) throws InterruptedException
fetchRange
in interface CacheCallback
InterruptedException
public QueueState getQueueState(String pubAgentName, String subAgentId)
getQueueState
in interface CacheCallback
public Set<String> getSubscribedAgentIds(String pubAgentName)
getSubscribedAgentIds
in interface CacheCallback
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.