Package | Description |
---|---|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.jmx | |
org.jgroups.mux |
Modifier and Type | Method and Description |
---|---|
protected void |
JChannel.checkClosedOrNotConnected() |
abstract boolean |
Channel.getAllStates(java.util.Vector targets,
long timeout)
Deprecated.
Not really needed - we always want to get the state from a single member
|
boolean |
JChannel.getAllStates(java.util.Vector targets,
long timeout)
Deprecated.
Not really needed - we always want to get the state from a single member,
use
JChannel.getState(org.jgroups.Address, long) instead |
abstract boolean |
Channel.getState(Address target,
long timeout)
Retrieve the state of the group.
|
boolean |
JChannel.getState(Address target,
long timeout)
Retrieves a full state from the target member.
|
abstract boolean |
Channel.getState(Address target,
java.lang.String state_id,
long timeout)
Fetches a partial state identified by state_id.
|
boolean |
JChannel.getState(Address target,
java.lang.String state_id,
long timeout)
Retrieves a substate (or partial state) indicated by state_id from the target member.
|
boolean |
JChannel.getState(Address target,
java.lang.String state_id,
long timeout,
boolean useFlushIfPresent)
Retrieves a substate (or partial state) indicated by state_id from the target member.
|
protected boolean |
JChannel.getState(Address target,
java.lang.String state_id,
long timeout,
java.util.concurrent.Callable<java.lang.Boolean> flushInvoker)
Retrieves a substate (or partial state) indicated by state_id from the target member.
|
abstract java.lang.Object |
Channel.peek(long timeout)
Deprecated.
Use a
Receiver instead, this method will not be available in JGroups 3.0 |
java.lang.Object |
JChannel.peek(long timeout)
Just peeks at the next message, view or block.
|
abstract java.lang.Object |
Channel.receive(long timeout)
Deprecated.
Use a
Receiver instead |
java.lang.Object |
JChannel.receive(long timeout)
Deprecated.
Use a
Receiver instead |
abstract void |
Channel.send(Address dst,
Address src,
java.io.Serializable obj)
Helper method.
|
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
|
abstract void |
Channel.send(Message msg)
Sends a message to a (unicast) destination.
|
void |
JChannel.send(Message msg)
Sends a message through the protocol stack.
|
Modifier and Type | Method and Description |
---|---|
void |
ReplicatedTree.fetchState(long timeout)
Fetch the group state from the current coordinator.
|
void |
MessageDispatcher.send(Message msg) |
void |
DistributedHashtable.start(long state_timeout)
Deprecated.
Fetches the state
|
void |
ReplicatedHashMap.start(long state_timeout)
Fetches the state
|
void |
DistributedQueue.start(long state_timeout) |
Constructor and Description |
---|
DistributedHashtable(PullPushAdapter adapter,
java.io.Serializable id,
long state_timeout)
Deprecated.
Uses a user-provided PullPushAdapter to create the dispatcher rather than a Channel.
|
ReplicatedHashtable(JChannel channel,
long state_timeout)
Deprecated.
|
ReplicatedHashtable(JChannel channel,
ReplicatedHashtable.StateTransferListener l,
long state_timeout)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
JChannelMBean.getState(Address target,
long timeout) |
boolean |
JChannel.getState(Address target,
long timeout) |
java.lang.Object |
JChannelMBean.peek(long timeout) |
java.lang.Object |
JChannel.peek(long timeout) |
java.lang.Object |
JChannelMBean.receive(long timeout) |
java.lang.Object |
JChannel.receive(long timeout) |
void |
JChannelMBean.send(Address dst,
Address src,
java.io.Serializable obj) |
void |
JChannel.send(Address dst,
Address src,
java.io.Serializable obj) |
void |
JChannelMBean.send(Message msg) |
void |
JChannel.send(Message msg) |
void |
JChannelMBean.sendToAll(java.lang.String msg) |
void |
JChannel.sendToAll(java.lang.String msg) |
Modifier and Type | Method and Description |
---|---|
boolean |
MuxChannel.getState(Address target,
java.lang.String state_id,
long timeout,
boolean useFlushIfPresent) |
void |
MuxChannel.send(Address dst,
Address src,
java.io.Serializable obj) |
void |
MuxChannel.send(Message msg) |
Copyright ? 1998-2008 Bela Ban. All Rights Reserved.