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:
createConsumer
in 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:
fetchRange
in interfaceCacheCallback
- Throws:
InterruptedException
-
getQueueState
- Specified by:
getQueueState
in interfaceCacheCallback
-
getSubscribedAgentIds
- Specified by:
getSubscribedAgentIds
in interfaceCacheCallback
-