org.apache.qpid.server.cluster
Interface GroupManager
- All Known Implementing Classes:
- DefaultGroupManager
public interface GroupManager
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)