Class 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.
    • Constructor Detail

      • DiscoveryService

        public DiscoveryService()
      • DiscoveryService

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

      • activate

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

        public void deactivate()
      • 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)