|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.sling.discovery.impl.topology.announcement.AnnouncementRegistryImpl
@Service(value=AnnouncementRegistry.class) public class AnnouncementRegistryImpl
Constructor Summary | |
---|---|
AnnouncementRegistryImpl()
|
Method Summary | |
---|---|
void |
addAllExcept(Announcement target,
org.apache.sling.discovery.ClusterView clusterView,
AnnouncementFilter filter)
Add all registered announcements to the given target announcement that are accepted by the given filter |
void |
checkExpiredAnnouncements()
Check for expired announcements and remove any if applicable |
boolean |
hasActiveAnnouncement(String ownerId)
Whether or not the given owner has an active (ie not expired) announcement registered |
Collection<Announcement> |
listAnnouncementsInSameCluster(org.apache.sling.discovery.ClusterView localClusterView)
list all announcements that were received by instances in the local cluster |
Collection<org.apache.sling.discovery.InstanceDescription> |
listInstances(org.apache.sling.discovery.ClusterView localClusterView)
Returns the list of instances contained in all non-expired announcements of this registry |
Collection<Announcement> |
listLocalAnnouncements()
list all announcements that were received (incoming or inherited) by this instance |
Collection<CachedAnnouncement> |
listLocalIncomingAnnouncements()
list all announcements that this instance received (incoming) |
long |
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 |
unregisterAnnouncement(String ownerId)
Unregister the announcement owned by the given slingId |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AnnouncementRegistryImpl()
Method Detail |
---|
public void unregisterAnnouncement(String ownerId)
AnnouncementRegistry
unregisterAnnouncement
in interface AnnouncementRegistry
public Collection<Announcement> listLocalAnnouncements()
AnnouncementRegistry
listLocalAnnouncements
in interface AnnouncementRegistry
public Collection<CachedAnnouncement> listLocalIncomingAnnouncements()
AnnouncementRegistry
listLocalIncomingAnnouncements
in interface AnnouncementRegistry
public Collection<Announcement> listAnnouncementsInSameCluster(org.apache.sling.discovery.ClusterView localClusterView)
AnnouncementRegistry
listAnnouncementsInSameCluster
in interface AnnouncementRegistry
public boolean hasActiveAnnouncement(String ownerId)
AnnouncementRegistry
hasActiveAnnouncement
in interface AnnouncementRegistry
public long registerAnnouncement(Announcement topologyAnnouncement)
AnnouncementRegistry
registerAnnouncement
in interface AnnouncementRegistry
public void addAllExcept(Announcement target, org.apache.sling.discovery.ClusterView clusterView, AnnouncementFilter filter)
AnnouncementRegistry
addAllExcept
in interface AnnouncementRegistry
public void checkExpiredAnnouncements()
AnnouncementRegistry
checkExpiredAnnouncements
in interface AnnouncementRegistry
public Collection<org.apache.sling.discovery.InstanceDescription> listInstances(org.apache.sling.discovery.ClusterView localClusterView)
AnnouncementRegistry
listInstances
in interface AnnouncementRegistry
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |