Class DiscoveryService
java.lang.Object
org.apache.sling.distribution.journal.impl.discovery.DiscoveryService
- All Implemented Interfaces:
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 Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionDiscoveryService(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, TopologyChangeHandler topologyChangeHandler, org.osgi.service.event.EventAdmin eventAdmin) -
Method Summary
Modifier and TypeMethodDescriptionvoidactivate(org.osgi.framework.BundleContext context) voidintgetSubscriberCount(String pubAgentName) voidhandleDiscovery(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.DiscoveryMessage disMsg) voidhandleLog(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.LogMessage logMsg) voidrun()
-
Field Details
-
KEY_MESSAGE
- See Also:
-
TOPIC_DISTRIBUTION_LOG
- See Also:
-
-
Constructor Details
-
DiscoveryService
public DiscoveryService() -
DiscoveryService
public DiscoveryService(org.apache.sling.distribution.journal.MessagingProvider messagingProvider, TopologyChangeHandler topologyChangeHandler, org.osgi.service.event.EventAdmin eventAdmin)
-
-
Method Details
-
activate
public void activate(org.osgi.framework.BundleContext context) -
deactivate
public void deactivate() -
getTopologyView
-
getSubscriberCount
-
run
public void run() -
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)
-