Interface CacheCallback

All Known Implementing Classes:
MessagingCacheCallback

public interface CacheCallback
  • Method Summary

    Modifier and Type
    Method
    Description
    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)
     
    getQueueState(String pubAgentName, String subAgentId)
     
     
  • Method Details

    • createConsumer

      Closeable createConsumer(org.apache.sling.distribution.journal.MessageHandler<org.apache.sling.distribution.journal.messages.PackageMessage> handler)
    • fetchRange

      List<org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.PackageMessage>> fetchRange(long minOffset, long maxOffset) throws InterruptedException
      Throws:
      InterruptedException
    • getQueueState

      QueueState getQueueState(String pubAgentName, String subAgentId)
    • getSubscribedAgentIds

      Set<String> getSubscribedAgentIds(String pubAgentName)