org.jgroups.blocks
public class DistributedTree extends Object implements MessageListener, MembershipListener
Nested Class Summary | |
---|---|
interface | DistributedTree.DistributedTreeListener |
interface | DistributedTree.ViewListener |
Field Summary | |
---|---|
protected Channel | channel |
protected RpcDispatcher | disp |
protected static Log | log |
Constructor Summary | |
---|---|
DistributedTree() | |
DistributedTree(String groupname, String channel_properties) | |
DistributedTree(PullPushAdapter adapter, Serializable id, long state_timeout) |
Method Summary | |
---|---|
void | add(String fqn) |
void | add(String fqn, Serializable element) |
void | add(String fqn, Serializable element, int timeout) |
void | addDistributedTreeListener(DistributedTree.DistributedTreeListener listener) |
void | addViewListener(DistributedTree.ViewListener listener) |
void | block() Block sending and receiving of messages until ViewAccepted is called |
boolean | exists(String fqn) |
Serializable | get(String fqn) |
Channel | getChannel()
Returns the Channel the DistributedTree is connected to |
Vector | getChildrenNames(String fqn) Returns all children of a Node as strings |
int | getGroupMembersNumber()
Returns the number of current members joined to the group |
String | getGroupName()
Returns the name of the group that the DistributedTree is connected to |
Object | getLocalAddress() |
byte[] | getState() Return a copy of the tree |
String | print() |
void | receive(Message msg) |
void | remove(String fqn) |
void | remove(String fqn, int timeout) |
void | removeDistributedTreeListener(DistributedTree.DistributedTreeListener listener) |
void | removeViewListener(DistributedTree.ViewListener listener) |
void | reset(String fqn, Serializable element) resets an existing node, useful after a merge when you want to tell other
members of your state, but do not wish to remove and then add as two separate calls |
void | reset(String fqn, Serializable element, int timeout) resets an existing node, useful after a merge when you want to tell other
members of your state, but do not wish to remove and then add as two separate calls |
void | set(String fqn, Serializable element) |
void | set(String fqn, Serializable element, int timeout) |
void | setDeadlockDetection(boolean flag) |
void | setState(byte[] data) |
void | start() |
void | start(long timeout) |
void | stop() |
void | suspect(Address suspected_mbr) Called when a member is suspected |
void | viewAccepted(View new_view) |
void | _add(String fqn) |
void | _add(String fqn, Serializable element) |
void | _remove(String fqn) |
void | _reset(String fqn, Serializable element) similar to set, but does not error if node does not exist, but rather does an add instead |
void | _set(String fqn, Serializable element) |
Returns: Channel
Returns: int
Returns: String