in src/main/java/org/apache/sling/distribution/journal/shared/OnlyOnLeader.java [62:73]
public void handleTopologyEvent(TopologyEvent event) {
TopologyEvent.Type eventType = event.getType();
if (eventType == TOPOLOGY_INIT || eventType == TOPOLOGY_CHANGED) {
if (event.getNewView().getLocalInstance().isLeader()) {
register();
} else {
unregister();
}
} else if (eventType == TOPOLOGY_CHANGING) {
unregister();
}
}