程序包 | 说明 |
---|---|
com.fr.third.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
com.fr.third.jgroups.auth | |
com.fr.third.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
com.fr.third.jgroups.blocks.mux | |
com.fr.third.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
com.fr.third.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
com.fr.third.jgroups.protocols.relay | |
com.fr.third.jgroups.protocols.tom | |
com.fr.third.jgroups.tests.perf | |
com.fr.third.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
限定符和类型 | 方法和说明 |
---|---|
Header |
Message.getHeader(short id) |
Header |
Message.putHeaderIfAbsent(short id,
Header hdr)
Puts a header given a key into the map, only if the key doesn't exist yet
|
protected static Header |
Message.readHeader(java.io.DataInput in) |
限定符和类型 | 方法和说明 |
---|---|
java.util.Map<java.lang.Short,Header> |
Message.getHeaders()
Returns a reference to the headers hashmap, which is immutable.
|
限定符和类型 | 方法和说明 |
---|---|
Message |
Message.putHeader(short id,
Header hdr)
Puts a header given an ID into the hashmap.
|
Header |
Message.putHeaderIfAbsent(short id,
Header hdr)
Puts a header given a key into the map, only if the key doesn't exist yet
|
protected static void |
Message.writeHeader(Header hdr,
java.io.DataOutput out) |
限定符和类型 | 类和说明 |
---|---|
static class |
DemoToken.DemoHeader |
限定符和类型 | 类和说明 |
---|---|
static class |
RequestCorrelator.Header
The header for RequestCorrelator messages
|
static class |
RequestCorrelator.MultiDestinationHeader |
限定符和类型 | 类和说明 |
---|---|
class |
MuxHeader
Header that identifies the target handler for multiplexed dispatches.
|
限定符和类型 | 类和说明 |
---|---|
class |
AuthHeader
AuthHeader is a holder object for the token that is passed from the joiner to the coordinator
|
static class |
COMPRESS.CompressHeader |
static class |
COUNTER.CounterHeader |
static class |
DAISYCHAIN.DaisyHeader |
static class |
ENCRYPT.EncryptHeader |
static class |
EXAMPLE.ExampleHeader |
static class |
Executing.ExecutorHeader |
class |
FcHeader
Header used by various flow control protocols
|
static class |
FD_ALL.HeartbeatHeader |
static class |
FD_ALL2.HeartbeatHeader |
static class |
FD_SOCK.FdHeader |
static class |
FD.FdHeader |
static class |
FORK.ForkHeader |
protected static class |
FORWARD_TO_COORD.ForwardHeader |
class |
FragHeader |
static class |
Locking.LockingHeader |
protected static class |
MERGE2.MergeHeader
已过时。
|
static class |
MERGE3.MergeHeader |
protected static class |
PERF.PerfHeader |
class |
PingHeader |
class |
PrioHeader
This Header class is used in conjunction with the PRIO protocol to prioritize message sending/receiving
Priority values are from 0 to 255 where 0 is the highest priority
Example of setting a message priority:
// Create a message to send to everyone
Message message = new Message( null, null, messagePayload );
// Add the priority protocol header
PrioHeader header = new PrioHeader( 1 );
short protocolId = ClassConfigurator.getProtocolId(PRIO.class);
message.putHeader( protocolId, header);
|
static class |
RELAY.RelayHeader |
protected static class |
RSVP.RsvpHeader |
class |
SaslHeader |
static class |
SCOPE.ScopeHeader
已过时。
|
static class |
SEQUENCER.SequencerHeader |
static class |
SEQUENCER2.SequencerHeader |
static class |
STOMP.StompHeader |
class |
TpHeader
Generic transport header, used by TP.
|
static class |
UNICAST.UnicastHeader
The following types and fields are serialized:
| DATA | seqno | conn_id | first |
| ACK | seqno |
| SEND_FIRST_SEQNO |
|
static class |
UNICAST2.Unicast2Header
The following types and fields are serialized:
| DATA | seqno | conn_id | first |
| ACK | seqno |
| SEND_FIRST_SEQNO | seqno |
|
static class |
UNICAST3.Header
The following types and fields are serialized:
| DATA | seqno | conn_id | first |
| ACK | seqno | timestamp |
| SEND_FIRST_SEQNO | timestamp |
| CLOSE | conn_id |
|
static class |
VERIFY_SUSPECT.VerifyHeader |
限定符和类型 | 类和说明 |
---|---|
static class |
FLUSH.FlushHeader |
static class |
GMS.GmsHeader |
class |
NakAckHeader |
class |
NakAckHeader2 |
static class |
STABLE.StableHeader |
static class |
STATE_TRANSFER.StateHeader
Wraps data for a state request/response.
|
static class |
StreamingStateTransfer.StateHeader |
限定符和类型 | 类和说明 |
---|---|
static class |
RELAY2.Relay2Header |
限定符和类型 | 类和说明 |
---|---|
class |
ToaHeader
The header for the Total Order Anycast (TOA) protocol
|
限定符和类型 | 类和说明 |
---|---|
protected static class |
MPerf.MPerfHeader |
限定符和类型 | 方法和说明 |
---|---|
Header |
Headers.getHeader(short id)
Returns the header associated with an ID
|
Header[] |
Headers.getRawHeaders() |
Header |
Headers.putHeaderIfAbsent(short id,
Header hdr)
Puts a header given a key into the map, only if the key doesn't exist yet
|
限定符和类型 | 方法和说明 |
---|---|
java.util.Map<java.lang.Short,Header> |
Headers.getHeaders() |
限定符和类型 | 方法和说明 |
---|---|
void |
Headers.putHeader(short id,
Header hdr)
Puts a header given a key into the hashmap.
|
Header |
Headers.putHeaderIfAbsent(short id,
Header hdr)
Puts a header given a key into the map, only if the key doesn't exist yet
|