|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ChannelClosedException | |
org.jgroups | |
org.jgroups.blocks |
Uses of ChannelClosedException in org.jgroups |
Methods in org.jgroups that throw ChannelClosedException | |
void |
JChannel.connect(java.lang.String channel_name)
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 |
void |
JChannel.send(Message msg)
implementation of the Transport interface. Sends a message through the protocol stack |
void |
JChannel.send(Address dst,
Address src,
java.io.Serializable obj)
creates a new message with the destination address, and the source address and the object as the message value |
java.lang.Object |
JChannel.receive(long timeout)
Blocking receive method. |
java.lang.Object |
JChannel.peek(long timeout)
Just peeks at the next message, view or block. |
boolean |
JChannel.getState(Address target,
long timeout)
Retrieves the current group state. |
boolean |
JChannel.getAllStates(java.util.Vector targets,
long timeout)
Retrieves the current group state. |
void |
EnsChannel.connect(java.lang.String channel_name)
|
void |
EnsChannel.send(Message msg)
|
void |
EnsChannel.send(Address dst,
Address src,
java.io.Serializable obj)
|
java.lang.Object |
EnsChannel.receive(long timeout)
|
java.lang.Object |
EnsChannel.peek(long timeout)
|
abstract void |
Channel.connect(java.lang.String channel_name)
Connects the channel to a group. |
abstract void |
Channel.send(Message msg)
Sends a message to a (unicast) destination. |
abstract void |
Channel.send(Address dst,
Address src,
java.io.Serializable obj)
Helper method. |
abstract java.lang.Object |
Channel.receive(long timeout)
Receives a message, a view change or a block event. |
abstract java.lang.Object |
Channel.peek(long timeout)
Returns the next message, view, block, suspect or other event without removing it from the queue. |
abstract boolean |
Channel.getState(Address target,
long timeout)
Retrieve the state of the group. |
abstract boolean |
Channel.getAllStates(java.util.Vector targets,
long timeout)
Retrieve all states of the group members. |
Uses of ChannelClosedException in org.jgroups.blocks |
Methods in org.jgroups.blocks that throw ChannelClosedException | |
void |
ReplicatedTree.fetchState(long timeout)
Fetch the group state from the current coordinator. |
void |
DistributedQueue.start(long state_timeout)
|
void |
MessageDispatcher.send(Message msg)
|
protected void |
DistributedHashtable.init(long state_timeout)
|
void |
DistributedHashtable.start(long state_timeout)
Fetches the state |
Constructors in org.jgroups.blocks that throw ChannelClosedException | |
ReplicatedHashtable(JChannel channel,
long state_timeout)
|
|
ReplicatedHashtable(JChannel channel,
ReplicatedHashtable.StateTransferListener l,
long state_timeout)
|
|
DistributedHashtable(JChannel channel,
long state_timeout)
|
|
DistributedHashtable(JChannel channel,
boolean persistent,
long state_timeout)
|
|
DistributedHashtable(PullPushAdapter adapter,
java.io.Serializable id,
long state_timeout)
Uses a user-provided PullPushAdapter to create the dispatcher rather than a Channel. |
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |