Frames | No Frames |
Methods which throw type org.jgroups.ChannelClosedException | |
void | Connects the channel to a group. |
void | EnsChannel.connect(String channel_name) |
void | Connects the channel to a group. If the channel is already connected, an error message will be printed to the error log If the channel is closed a ChannelClosed exception will be thrown This method starts the protocol stack by calling ProtocolStack.start then it sends an Event.CONNECT event down the stack and waits to receive a CONNECT_OK event Once the CONNECT_OK event arrives from the protocol stack, any channel listeners are notified and the channel is considered connected |
boolean | Channel.getAllStates(Vector targets, long timeout) Retrieve all states of the group members. |
boolean | JChannel.getAllStates(Vector targets, long timeout) Retrieves the current group state. |
boolean | Retrieve the state of the group. |
boolean | Retrieves the current group state. |
Object | Returns the next message, view, block, suspect or other event without removing
it from the queue. |
Object | EnsChannel.peek(long timeout) |
Object | Just peeks at the next message, view or block. |
Object | Receives a message, a view change or a block event. |
Object | EnsChannel.receive(long timeout) |
Object | Blocking receive method. |
void | Helper method. |
void | |
void | creates a new message with the destination address, and the source address
and the object as the message value
|
void | Sends a message to a (unicast) destination. |
void | |
void | implementation of the Transport interface. Sends a message through the protocol stack |
Constructors which throw type org.jgroups.ChannelClosedException | |
DistributedHashtable.DistributedHashtable(PullPushAdapter adapter, Serializable id, long state_timeout) Uses a user-provided PullPushAdapter to create the dispatcher rather than a Channel. | |
ReplicatedHashtable.ReplicatedHashtable(JChannel channel, ReplicatedHashtable.StateTransferListener l, long state_timeout) |
Methods which throw type org.jgroups.ChannelClosedException | |
void | ReplicatedTree.fetchState(long timeout) Fetch the group state from the current coordinator. |
void | DistributedHashtable.init(long state_timeout) |
void | |
void | DistributedHashtable.start(long state_timeout) Fetches the state
|
void | DistributedQueue.start(long state_timeout) |