org.apache.qpid.server.cluster
Interface GroupManager

All Known Implementing Classes:
DefaultGroupManager

public interface GroupManager


Method Summary
 void addMemberhipChangeListener(MembershipChangeListener l)
           
 void broadcast(Sendable message)
           
 void broadcast(Sendable message, BroadcastPolicy policy, GroupResponseHandler callback)
           
 void establish()
          Establish a new cluster with the local member as the leader.
 MemberHandle getLocal()
           
 JoinState getState()
           
 void handleJoin(MemberHandle member)
           
 void handleLeave(MemberHandle member)
           
 void handleMembershipAnnouncement(java.lang.String membership)
           
 void handlePing(MemberHandle member, long load)
           
 void handleSuspect(MemberHandle member)
           
 void handleSynch(MemberHandle member)
           
 boolean isLeader()
           
 boolean isLeader(MemberHandle handle)
           
 boolean isMember(MemberHandle member)
           
 void join(MemberHandle member)
          Join the cluster to which member belongs
 void leave()
           
 MemberHandle redirect()
           
 void removeMemberhipChangeListener(MembershipChangeListener l)
           
 void send(MemberHandle broker, Sendable message)
           
 

Method Detail

establish

void establish()
Establish a new cluster with the local member as the leader.


join

void join(MemberHandle member)
          throws org.apache.qpid.AMQException
Join the cluster to which member belongs

Throws:
org.apache.qpid.AMQException

broadcast

void broadcast(Sendable message)
               throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

broadcast

void broadcast(Sendable message,
               BroadcastPolicy policy,
               GroupResponseHandler callback)
               throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

send

void send(MemberHandle broker,
          Sendable message)
          throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

leave

void leave()
           throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

handleJoin

void handleJoin(MemberHandle member)
                throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

handleLeave

void handleLeave(MemberHandle member)
                 throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

handleSuspect

void handleSuspect(MemberHandle member)
                   throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

handlePing

void handlePing(MemberHandle member,
                long load)

handleMembershipAnnouncement

void handleMembershipAnnouncement(java.lang.String membership)
                                  throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

handleSynch

void handleSynch(MemberHandle member)

isLeader

boolean isLeader()

isLeader

boolean isLeader(MemberHandle handle)

isMember

boolean isMember(MemberHandle member)

redirect

MemberHandle redirect()

getLocal

MemberHandle getLocal()

getState

JoinState getState()

addMemberhipChangeListener

void addMemberhipChangeListener(MembershipChangeListener l)

removeMemberhipChangeListener

void removeMemberhipChangeListener(MembershipChangeListener l)