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.mux |
Modifier and Type | Method and Description |
---|---|
protected void |
JChannel.checkClosed()
health check
throws a ChannelClosed exception if the channel is closed |
protected void |
JChannel.checkClosedOrNotConnected() |
boolean |
JChannel.getAllStates(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.getAllStates(Vector targets,
long timeout)
Deprecated.
Not really needed - we always want to get the state from a single member
|
boolean |
JChannel.getState(Address target,
long timeout)
Retrieves a full state from the target member.
|
abstract boolean |
Channel.getState(Address target,
long timeout)
Retrieve the state of the group.
|
boolean |
JChannel.getState(Address target,
String state_id,
long timeout)
Retrieves a substate (or partial state) indicated by state_id from the target member.
|
abstract boolean |
Channel.getState(Address target,
String state_id,
long timeout)
Fetches a partial state identified by state_id.
|
boolean |
JChannel.getState(Address target,
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,
String state_id,
long timeout,
Callable<Boolean> flushInvoker)
Retrieves a substate (or partial state) indicated by state_id from the target member.
|
Object |
JChannel.peek(long timeout)
Just peeks at the next message, view or block.
|
abstract Object |
Channel.peek(long timeout)
Deprecated.
Use a
Receiver instead, this method will not be available in JGroups 3.0 |
Object |
JChannel.receive(long timeout)
Deprecated.
Use a
Receiver instead |
abstract Object |
Channel.receive(long timeout)
Deprecated.
Use a
Receiver instead |
void |
JChannel.send(Address dst,
Address src,
byte[] buf) |
abstract void |
Channel.send(Address dst,
Address src,
byte[] buf) |
void |
JChannel.send(Address dst,
Address src,
byte[] buf,
int offset,
int length) |
abstract void |
Channel.send(Address dst,
Address src,
byte[] buf,
int offset,
int length) |
void |
JChannel.send(Address dst,
Address src,
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(Address dst,
Address src,
Serializable obj)
Helper method.
|
void |
JChannel.send(Message msg)
Sends a message through the protocol stack.
|
abstract void |
Channel.send(Message msg)
Sends a message to a (unicast) destination.
|
Modifier and Type | Method and Description |
---|---|
void |
ReplicatedTree.fetchState(long timeout)
Fetch the group state from the current coordinator.
|
void |
MessageDispatcher.send(Message msg)
Deprecated.
|
void |
ReplicatedHashMap.start(long state_timeout)
Fetches the state
|
void |
DistributedQueue.start(long state_timeout) |
Modifier and Type | Method and Description |
---|---|
void |
MuxChannel.connect(String channel_name)
Deprecated.
|
boolean |
MuxChannel.getState(Address target,
String state_id,
long timeout,
boolean useFlushIfPresent)
Deprecated.
|
void |
MuxChannel.send(Address dst,
Address src,
Serializable obj)
Deprecated.
|
void |
MuxChannel.send(Message msg)
Deprecated.
|
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.