in src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistributedEventNotifierManager.java [97:110]
public void handleTopologyEvent(TopologyEvent event) {
if (config.deduplicateEvent()) {
Type eventType = event.getType();
if (eventType == TOPOLOGY_INIT || eventType == TOPOLOGY_CHANGED) {
if (event.getNewView().getLocalInstance().isLeader()) {
registerService();
} else {
unregisterService();
}
} else if (eventType == TOPOLOGY_CHANGING) {
unregisterService();
}
}
}