in src/main/java/org/apache/sling/discovery/base/connectors/ping/ConnectorRegistryImpl.java [143:153]
public void pingOutgoingConnectors(boolean force) {
List<TopologyConnectorClient> outgoingTemplatesClone;
synchronized (outgoingClientsMap) {
outgoingTemplatesClone = new ArrayList<>(
outgoingClientsMap.values());
}
for (Iterator<TopologyConnectorClient> it = outgoingTemplatesClone
.iterator(); it.hasNext();) {
it.next().ping(force);
}
}