org.apache.sling.discovery.base.connectors.announcement

Interface AnnouncementRegistry

All Known Implementing Classes:

AnnouncementRegistryImpl

public interface AnnouncementRegistry

The announcement registry keeps track of all the announcement that this instance either received by a joined topology connector or that a topology connector inherited from the counterpart (the topology connector servlet)

Method Summary

Modifier and Type	Method and Description
void	addAllExcept(Announcement target, ClusterView localClusterView, 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(java.lang.String ownerId) Whether or not the given owner has an active (ie not expired) announcement registered
java.util.Collection<Announcement>	listAnnouncementsInSameCluster(ClusterView localClusterView) list all announcements that were received by instances in the local cluster
java.util.Collection<InstanceDescription>	listInstances(ClusterView localClusterView) Returns the list of instances contained in all non-expired announcements of this registry
java.util.Collection<Announcement>	listLocalAnnouncements() list all announcements that were received (incoming or inherited) by this instance
java.util.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(java.lang.String ownerId) Unregister the announcement owned by the given slingId

Method Detail

registerAnnouncement

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)

Returns:

the backoff interval (in seconds) for stable connectors - or -1 if the registration was not successful (likely indicating a loop)

listAnnouncementsInSameCluster

java.util.Collection<Announcement> listAnnouncementsInSameCluster(ClusterView localClusterView)

list all announcements that were received by instances in the local cluster

listLocalAnnouncements

java.util.Collection<Announcement> listLocalAnnouncements()

list all announcements that were received (incoming or inherited) by this instance

listLocalIncomingAnnouncements

java.util.Collection<CachedAnnouncement> listLocalIncomingAnnouncements()

list all announcements that this instance received (incoming)

checkExpiredAnnouncements

void checkExpiredAnnouncements()

Check for expired announcements and remove any if applicable

listInstances

java.util.Collection<InstanceDescription> listInstances(ClusterView localClusterView)

Returns the list of instances contained in all non-expired announcements of this registry

addAllExcept

void addAllExcept(Announcement target,
                  ClusterView localClusterView,
                  AnnouncementFilter filter)

Add all registered announcements to the given target announcement that are accepted by the given filter

unregisterAnnouncement

void unregisterAnnouncement(java.lang.String ownerId)

Unregister the announcement owned by the given slingId

hasActiveAnnouncement

boolean hasActiveAnnouncement(java.lang.String ownerId)

Whether or not the given owner has an active (ie not expired) announcement registered