Package | Description |
---|---|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
org.jgroups.auth | |
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.blocks.mux | |
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.protocols.relay | |
org.jgroups.protocols.tom | |
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Field and Description |
---|---|
protected Header[] |
Message.headers
All headers are placed here
|
Modifier and Type | Method and Description |
---|---|
protected static Header[] |
Message.createHeaders(int size) |
Header |
Message.getHeader(short id) |
protected static Header |
Message.readHeader(java.io.DataInput in) |
Header |
Header.setProtId(short id) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.Short,Header> |
Message.getHeaders()
Returns a reference to the headers hashmap, which is immutable.
|
Modifier and Type | Method and Description |
---|---|
Message |
Message.putHeader(short id,
Header hdr)
Puts a header given an ID into the hashmap.
|
Message |
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) |
Modifier and Type | Class and Description |
---|---|
static class |
DemoToken.DemoHeader |
Modifier and Type | Class and Description |
---|---|
static class |
RequestCorrelator.Header
The header for RequestCorrelator messages
|
static class |
RequestCorrelator.MultiDestinationHeader |
Modifier and Type | Class and Description |
---|---|
class |
MuxHeader
Header that identifies the target handler for multiplexed dispatches.
|
Modifier and Type | Class and Description |
---|---|
protected static class |
ABP.ABPHeader |
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
Deprecated.
|
class |
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
Deprecated.
|
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
Deprecated.
|
static class |
SEQUENCER.SequencerHeader |
static class |
SEQUENCER2.SequencerHeader |
static class |
STOMP.StompHeader |
class |
TpHeader
Generic transport header, used by TP.
|
static class |
UNICAST.UnicastHeader
Deprecated.
The following types and fields are serialized:
|
static class |
UNICAST2.Unicast2Header
Deprecated.
The following types and fields are serialized:
|
static class |
UNICAST3.Header
The following types and fields are serialized:
|
static class |
VERIFY_SUSPECT.VerifyHeader |
Modifier and Type | Method and Description |
---|---|
protected Header |
MFC.getCreditRequestHeader() |
protected abstract Header |
FlowControl.getCreditRequestHeader() |
protected Header |
UFC.getCreditRequestHeader() |
protected Header |
MFC.getReplenishHeader() |
protected abstract Header |
FlowControl.getReplenishHeader() |
protected Header |
UFC.getReplenishHeader() |
Modifier and Type | Class and Description |
---|---|
static class |
FLUSH.FlushHeader |
static class |
GMS.GmsHeader |
class |
NakAckHeader |
class |
NakAckHeader2
Header used by
NAKACK2 |
static class |
STABLE.StableHeader |
static class |
STATE_TRANSFER.StateHeader
Wraps data for a state request/response.
|
static class |
StreamingStateTransfer.StateHeader |
Modifier and Type | Class and Description |
---|---|
static class |
RELAY2.Relay2Header |
Modifier and Type | Class and Description |
---|---|
class |
ToaHeader
The header for the Total Order Anycast (TOA) protocol
|
Modifier and Type | Method and Description |
---|---|
static Header[] |
Headers.copy(Header[] headers) |
static Header |
Headers.getHeader(Header[] hdrs,
short id)
Returns the header associated with an ID
|
static Header[] |
Headers.putHeader(Header[] headers,
short id,
Header hdr,
boolean replace_if_present)
Adds hdr at the next available slot.
|
static Header[] |
Headers.resize(Header[] headers)
Increases the capacity of the array and copies the contents of the old into the new array
|
Modifier and Type | Method and Description |
---|---|
static java.util.Map<java.lang.Short,Header> |
Headers.getHeaders(Header[] hdrs) |
Modifier and Type | Method and Description |
---|---|
static Header[] |
Headers.copy(Header[] headers) |
static Header |
Headers.getHeader(Header[] hdrs,
short id)
Returns the header associated with an ID
|
static java.util.Map<java.lang.Short,Header> |
Headers.getHeaders(Header[] hdrs) |
static int |
Headers.marshalledSize(Header[] hdrs) |
static java.lang.String |
Headers.printHeaders(Header[] hdrs) |
static java.lang.String |
Headers.printObjectHeaders(Header[] hdrs) |
static Header[] |
Headers.putHeader(Header[] headers,
short id,
Header hdr,
boolean replace_if_present)
Adds hdr at the next available slot.
|
static Header[] |
Headers.putHeader(Header[] headers,
short id,
Header hdr,
boolean replace_if_present)
Adds hdr at the next available slot.
|
static Header[] |
Headers.resize(Header[] headers)
Increases the capacity of the array and copies the contents of the old into the new array
|
static int |
Headers.size(Header[] hdrs) |
static int |
Headers.size(Header[] hdrs,
short... excluded_ids) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.