public interface CacheCallback
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) |
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) throws InterruptedException
InterruptedException
QueueState getQueueState(String pubAgentName, String subAgentId)
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.