Class MessagingCacheCallback
java.lang.Object
org.apache.sling.distribution.journal.impl.publisher.MessagingCacheCallback
- All Implemented Interfaces:
CacheCallback
-
Constructor Summary
ConstructorsConstructorDescriptionMessagingCacheCallback(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, String packageTopic, PublishMetrics publishMetrics, DiscoveryService discoveryService, Consumer<org.apache.sling.distribution.journal.messages.ClearCommand> commandSender) -
Method Summary
Modifier and TypeMethodDescriptioncreateConsumer(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) getQueueState(String pubAgentName, String subAgentId) getSubscribedAgentIds(String pubAgentName)
-
Constructor Details
-
MessagingCacheCallback
public MessagingCacheCallback(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, String packageTopic, PublishMetrics publishMetrics, DiscoveryService discoveryService, Consumer<org.apache.sling.distribution.journal.messages.ClearCommand> commandSender)
-
-
Method Details
-
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
- Specified by:
getQueueStatein interfaceCacheCallback
-
getSubscribedAgentIds
- Specified by:
getSubscribedAgentIdsin interfaceCacheCallback
-