Package | Description |
---|---|
org.apache.sling.discovery.base.connectors.announcement |
Provides topology announcement implementations for discovery
implementors that choose to extend from discovery.base
|
Modifier and Type | Method and Description |
---|---|
static Announcement |
Announcement.fromJSON(java.lang.String topologyAnnouncementJSON)
Create an announcement form json
|
Announcement |
CachedAnnouncement.getAnnouncement() |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<Announcement> |
AnnouncementRegistryImpl.listAnnouncementsInSameCluster(ClusterView localClusterView) |
java.util.Collection<Announcement> |
AnnouncementRegistry.listAnnouncementsInSameCluster(ClusterView localClusterView)
list all announcements that were received by instances in the local cluster
|
java.util.Collection<Announcement> |
AnnouncementRegistryImpl.listLocalAnnouncements() |
java.util.Collection<Announcement> |
AnnouncementRegistry.listLocalAnnouncements()
list all announcements that were received (incoming or inherited) by this instance
|
Modifier and Type | Method and Description |
---|---|
boolean |
AnnouncementFilter.accept(java.lang.String receivingSlingId,
Announcement announcement)
Check if the provided announcement, which was received by the provided
slingId can be accepted or not.
|
void |
AnnouncementRegistryImpl.addAllExcept(Announcement target,
ClusterView clusterView,
AnnouncementFilter filter) |
void |
AnnouncementRegistry.addAllExcept(Announcement target,
ClusterView localClusterView,
AnnouncementFilter filter)
Add all registered announcements to the given target announcement that are accepted by the given filter
|
void |
Announcement.addIncomingTopologyAnnouncement(Announcement incomingTopologyAnnouncement)
adds an incoming announcement to this announcement
|
boolean |
Announcement.correspondsTo(Announcement announcement)
Compare this Announcement with another one, ignoring the 'created'
property - which gets added to the JSON object automatically due
to SLING-3389 wire-backwards-compatibility - and backoffInterval
introduced as part of SLING-3382
|
long |
AnnouncementRegistryImpl.registerAnnouncement(Announcement topologyAnnouncement) |
long |
AnnouncementRegistry.registerAnnouncement(Announcement topologyAnnouncement)
Register the given announcement - and returns the backoff interval (in seconds)
for stable connectors
- or -1 if the registration was not successful (likely indicating a loop)
|
void |
Announcement.registerPing(Announcement incomingAnnouncement) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.