in src/main/java/org/apache/sling/discovery/base/connectors/announcement/AnnouncementRegistryImpl.java [259:271]
private final Collection<Announcement> fillWithCachedAnnouncements(
final Collection<Announcement> incomingAnnouncements) {
for (Iterator<Entry<String, CachedAnnouncement>> it = ownAnnouncementsCache.entrySet().iterator(); it
.hasNext();) {
final Entry<String, CachedAnnouncement> entry = it.next();
if (entry.getValue().hasExpired()) {
// filter this one out then
continue;
}
incomingAnnouncements.add(entry.getValue().getAnnouncement());
}
return incomingAnnouncements;
}