java.lang.Object
org.apache.sling.distribution.journal.impl.discovery.DiscoveryService
All Implemented Interfaces:
Runnable

@ParametersAreNonnullByDefault public class DiscoveryService extends Object implements Runnable
Listens for discovery messages and tracks presence of Subscribers as well as the last processed offset of each Subscriber This component is only activated when there is at least one DistributionSubscriber agent configured. This component is meant to be shared by Publisher agents.
  • Field Details

  • Constructor Details

    • DiscoveryService

      public DiscoveryService()
    • DiscoveryService

      public DiscoveryService(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, TopologyChangeHandler topologyChangeHandler, Topics topics, org.osgi.service.event.EventAdmin eventAdmin)
  • Method Details

    • activate

      public void activate(org.osgi.framework.BundleContext context)
    • deactivate

      public void deactivate()
    • getTopologyView

      public TopologyView getTopologyView()
    • getSubscriberCount

      public int getSubscriberCount(String pubAgentName)
    • run

      public void run()
      Specified by:
      run in interface Runnable
    • handleDiscovery

      public void handleDiscovery(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.DiscoveryMessage disMsg)
    • handleLog

      public void handleLog(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.LogMessage logMsg)