in src/main/java/org/apache/sling/discovery/base/connectors/announcement/AnnouncementRegistryImpl.java [585:602]
public synchronized Collection<InstanceDescription> listInstances(final ClusterView localClusterView) {
logger.debug("listInstances: start. localClusterView: {}", localClusterView);
final Collection<InstanceDescription> instances = new LinkedList<>();
final Collection<Announcement> announcements = listAnnouncementsInSameCluster(localClusterView);
if (announcements == null) {
logger.debug("listInstances: no announcement found. end. instances: {}", instances);
return instances;
}
for (Iterator<Announcement> it = announcements.iterator(); it.hasNext();) {
final Announcement announcement = it.next();
logger.debug("listInstances: adding announcement: {}", announcement);
instances.addAll(announcement.listInstances());
}
logger.debug("listInstances: announcements added. end. instances: {}", instances);
return instances;
}