public class DistributedTree extends Object implements MessageListener, MembershipListener
Modifier and Type | Class and Description |
---|---|
static interface |
DistributedTree.DistributedTreeListener |
static interface |
DistributedTree.ViewListener |
Modifier and Type | Field and Description |
---|---|
protected Channel |
channel |
protected RpcDispatcher |
disp |
protected static Log |
log |
protected boolean |
rc |
protected boolean |
send_message
Determines when the updates have to be sent across the network, avoids sending unnecessary
messages when there are no member in the group
|
Constructor and Description |
---|
DistributedTree() |
DistributedTree(PullPushAdapter adapter,
Serializable id,
long state_timeout) |
DistributedTree(String groupname,
String channel_properties) |
Modifier and Type | Method and Description |
---|---|
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) |
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)
Called when a message is received.
|
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)
Sets the group state; e.g., when joining.
|
void |
start() |
void |
start(long timeout) |
void |
stop() |
void |
suspect(Address suspected_mbr)
Called when a member is suspected
|
void |
viewAccepted(View new_view)
Called when a change in membership has occurred.
|
protected Channel channel
protected RpcDispatcher disp
protected boolean rc
protected boolean send_message
protected static final Log log
public DistributedTree()
public DistributedTree(PullPushAdapter adapter, Serializable id, long state_timeout) throws ChannelException
ChannelException
public Object getLocalAddress()
public void setDeadlockDetection(boolean flag)
public void stop()
public void addDistributedTreeListener(DistributedTree.DistributedTreeListener listener)
public void removeDistributedTreeListener(DistributedTree.DistributedTreeListener listener)
public void addViewListener(DistributedTree.ViewListener listener)
public void removeViewListener(DistributedTree.ViewListener listener)
public void add(String fqn)
public void add(String fqn, Serializable element)
public void reset(String fqn, Serializable element)
public void remove(String fqn)
public void add(String fqn, Serializable element, int timeout)
public void reset(String fqn, Serializable element, int timeout)
public void remove(String fqn, int timeout)
public boolean exists(String fqn)
public Serializable get(String fqn)
public void set(String fqn, Serializable element)
public void set(String fqn, Serializable element, int timeout)
public Vector getChildrenNames(String fqn)
public String print()
public String getGroupName()
public Channel getChannel()
public int getGroupMembersNumber()
public void _add(String fqn)
public void _add(String fqn, Serializable element)
public void _remove(String fqn)
public void _set(String fqn, Serializable element)
public void _reset(String fqn, Serializable element)
public void receive(Message msg)
MessageListener
receive
in interface MessageListener
public byte[] getState()
getState
in interface MessageListener
public void setState(byte[] data)
MessageListener
setState
in interface MessageListener
public void viewAccepted(View new_view)
MembershipListener
Channel.connect(String)
returns.viewAccepted
in interface MembershipListener
public void suspect(Address suspected_mbr)
suspect
in interface MembershipListener
public void block()
block
in interface MembershipListener
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.