Interface CacheCallback

    • Method Detail

      • 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
      • getSubscribedAgentIds

        Set<String> getSubscribedAgentIds​(String pubAgentName)