Class MessagingCacheCallback
- java.lang.Object
-
- org.apache.sling.distribution.journal.impl.publisher.MessagingCacheCallback
-
- All Implemented Interfaces:
CacheCallback
public class MessagingCacheCallback extends Object implements CacheCallback
-
-
Constructor Summary
Constructors Constructor Description MessagingCacheCallback(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, String packageTopic, DistributionMetricsService distributionMetricsService, DiscoveryService discoveryService, Consumer<org.apache.sling.distribution.journal.messages.ClearCommand> commandSender)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CloseablecreateConsumer(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)QueueStategetQueueState(String pubAgentName, String subAgentId)Set<String>getSubscribedAgentIds(String pubAgentName)
-
-
-
Constructor Detail
-
MessagingCacheCallback
public MessagingCacheCallback(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, String packageTopic, DistributionMetricsService distributionMetricsService, DiscoveryService discoveryService, Consumer<org.apache.sling.distribution.journal.messages.ClearCommand> commandSender)
-
-
Method Detail
-
createConsumer
public Closeable createConsumer(org.apache.sling.distribution.journal.MessageHandler<org.apache.sling.distribution.journal.messages.PackageMessage> handler)
- Specified by:
createConsumerin interfaceCacheCallback
-
fetchRange
public List<org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.PackageMessage>> fetchRange(long minOffset, long maxOffset) throws InterruptedException
- Specified by:
fetchRangein interfaceCacheCallback- Throws:
InterruptedException
-
getQueueState
public QueueState getQueueState(String pubAgentName, String subAgentId)
- Specified by:
getQueueStatein interfaceCacheCallback
-
getSubscribedAgentIds
public Set<String> getSubscribedAgentIds(String pubAgentName)
- Specified by:
getSubscribedAgentIdsin interfaceCacheCallback
-
-