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 TypeMethodDescriptionvoid
activate
(org.osgi.framework.BundleContext context) void
int
getSubscriberCount
(String pubAgentName) void
handleDiscovery
(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.DiscoveryMessage disMsg) void
handleLog
(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.LogMessage logMsg) void
run()
-
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)
-