Class Membership

  • All Implemented Interfaces:

    public class Membership
    extends java.lang.Object
    implements java.lang.Cloneable
    A membership implementation using simple multicast. This is the representation of a multicast membership. This class is responsible for maintaining a list of active cluster nodes in the cluster. If a node fails to send out a heartbeat, the node will be dismissed.
    Peter Rossbach
    • Field Detail


        protected static final Member[] EMPTY_MEMBERS
      • local

        protected final Member local
        The local member.
      • members

        protected volatile Member[] members
        A list of all the members in the cluster.
      • memberComparator

        protected final java.util.Comparator<Member> memberComparator
        Comparator for sorting members by alive time.
    • Constructor Detail

      • Membership

        public Membership​(Member local,
                          boolean includeLocal)
        Constructs a new membership
        local - - has to be the name of the local member. Used to filter the local member from the cluster membership
        includeLocal - - TBA
      • Membership

        public Membership​(Member local)
      • Membership

        public Membership​(Member local,
                          java.util.Comparator<Member> comp)
      • Membership

        public Membership​(Member local,
                          java.util.Comparator<Member> comp,
                          boolean includeLocal)
    • Method Detail

      • clone

        public Membership clone()
        clone in class java.lang.Object
      • reset

        public void reset()
        Reset the membership and start over fresh. i.e., delete all the members and wait for them to ping again and join this membership.
      • memberAlive

        public boolean memberAlive​(Member member)
        Notify the membership that this member has announced itself.
        member - - the member that just pinged us
        - true if this member is new to the cluster, false otherwise.
        - false if this member is the local member or updated.
      • addMember

        public Membership.MbrEntry addMember​(Member member)
        Add a member to this component and sort array with memberComparator
        member - The member to add
        The member entry created for this new member.
      • removeMember

        public void removeMember​(Member member)
        Remove a member from this component.
        member - The member to remove
      • expire

        public Member[] expire​(long maxtime)
        Runs a refresh cycle and returns a list of members that has expired. This also removes the members from the membership, in such a way that getMembers() = getMembers() - expire()
        maxtime - - the max time a member can remain unannounced before it is considered dead.
        the list of expired members
      • hasMembers

        public boolean hasMembers()
        Returning that service has members or not.
        true if there are one or more members, otherwise false
      • contains

        public boolean contains​(Member mbr)
      • getMembers

        public Member[] getMembers()
        Returning a list of all the members in the membership. We not need a copy: add and remove generate new arrays.
        An array of the current members