See: Description
| Interface | Description |
|---|---|
| AUTH.UpHandler |
Interface to provide callbacks for handling up events
|
| Bundler |
Pluggable way to collect messages and send them as batches
|
| FD_HOST.PingCommand |
Command used to check whether a given host is alive, periodically called
|
| SSL_KEY_EXCHANGE.SessionVerifier | |
| TUNNEL.TUNNELPolicy |
| Class | Description |
|---|---|
| ABP |
Alternating Bit Protocol.
|
| ABP.ABPHeader | |
| ASYM_ENCRYPT |
Encrypts and decrypts communication in JGroups by using a secret key distributed to all cluster members by the
key server (coordinator) using asymmetric (public/private key) encryption.
The secret key is identical for all cluster members and is used to encrypt messages when sending and decrypt them when receiving messages. |
| AUTH |
The AUTH protocol adds a layer of authentication to JGroups.
|
| AuthHeader |
AuthHeader is a holder object for the token that is passed from the joiner to the coordinator
|
| BARRIER |
All messages up the stack have to go through a barrier (read lock, RL).
|
| BaseBundler |
Implements storing of messages in a hashmap and sending of single messages and message batches.
|
| BasicTCP |
Shared base class for TCP protocols
|
| BPING |
Broadcast PING.
|
| CENTRAL_EXECUTOR |
This is a central executor service where each request is sent to the coordinator
for either a task or a current waiting thread.
|
| CENTRAL_LOCK |
Implementation of a locking protocol which acquires locks by contacting the coordinator.
|
| CertficateCNMatcher |
Sample implementation of
SSL_KEY_EXCHANGE.SessionVerifier |
| COMPRESS |
Compresses the payload of a message.
|
| COMPRESS.CompressHeader | |
| COUNTER |
Protocol which is used by
CounterService to provide a distributed atomic counter |
| COUNTER.AddAndGetRequest | |
| COUNTER.BooleanResponse | |
| COUNTER.CompareAndSetRequest | |
| COUNTER.CounterHeader | |
| COUNTER.DeleteRequest | |
| COUNTER.ExceptionResponse | |
| COUNTER.GetOrCreateRequest | |
| COUNTER.GetOrCreateResponse | |
| COUNTER.ReconcileRequest | |
| COUNTER.ReconcileResponse | |
| COUNTER.Request | |
| COUNTER.ResendPendingRequests | |
| COUNTER.Response | |
| COUNTER.SetRequest | |
| COUNTER.SimpleRequest | |
| COUNTER.SimpleResponse |
Response without data
|
| COUNTER.UpdateRequest | |
| COUNTER.ValueResponse | |
| COUNTER.VersionedValue | |
| DAISYCHAIN |
Implementation of daisy chaining.
|
| DAISYCHAIN.DaisyHeader | |
| DELAY |
Delays incoming/outgoing messages by a random number of milliseconds (range between 0 and n
where n is determined by the user) and nanoseconds (constant amount).
|
| DELIVERY_TIME |
Protocol measuring delivery times.
|
| DISCARD |
Discards up or down messages based on a percentage; e.g., setting property 'up' to 0.1 causes 10%
of all up messages to be discarded.
|
| DISCARD_PAYLOAD |
Discards a message whose sequence number (in the payload, as a Long) matches seqno 2 times,
before passing it down.
|
| Discovery |
The Discovery protocol retrieves the initial membership (used by GMS and MERGE3) by sending discovery requests.
|
| DUPL |
Duplicates outgoing or incoming messages by copying them
|
| ENCRYPT | Deprecated
Use
ASYM_ENCRYPT or SYM_ENCRYPT instead |
| ENCRYPT.EncryptHeader | |
| EncryptBase |
Super class of symmetric (
SYM_ENCRYPT) and asymmetric (ASYM_ENCRYPT) encryption protocols. |
| EncryptHeader | |
| EXAMPLE |
Example of a protocol layer.
|
| EXAMPLE.ExampleHeader | |
| Executing |
This is the base protocol used for executions.
|
| Executing.ExecutorHeader | |
| Executing.Owner | |
| Executing.Request | |
| Executing.RequestWithThread | |
| FC | Deprecated
Succeeded by MFC and UFC
|
| FcHeader |
Header used by various flow control protocols
|
| FD |
Failure detection based on simple heartbeat protocol.
|
| FD_ALL |
Failure detection based on simple heartbeat protocol.
|
| FD_ALL.HeartbeatHeader | |
| FD_ALL2 |
Failure detection based on simple heartbeat protocol.
|
| FD_ALL2.HeartbeatHeader | |
| FD_HOST |
Failure detection protocol which detects the crash or hanging of entire hosts and suspects all cluster members
on those hosts.
|
| FD_HOST.CommandExecutor | |
| FD_HOST.CommandExecutor2 | |
| FD_HOST.ExternalPingCommand | |
| FD_HOST.IsReachablePingCommand | |
| FD_PING | Deprecated
Use
FD_HOST instead. |
| FD_PING.Pinger | |
| FD_SOCK |
Failure detection protocol based on sockets.
|
| FD_SOCK.ClientConnectionHandler |
Handles a client connection; multiple client can connect at the same time
|
| FD_SOCK.FdHeader | |
| FD.FdHeader | |
| FILE_PING |
Simple discovery protocol which uses a file on shared storage such as an SMB share, NFS mount or S3.
|
| FlowControl |
Simple flow control protocol based on a credit system.
|
| FORK |
The FORK protocol; multiplexes messages to different forks in a stack (https://issues.jboss.org/browse/JGRP-1613).
|
| FORK.ForkHeader | |
| FORWARD_TO_COORD |
Forwards a message to the current coordinator.
|
| FORWARD_TO_COORD.ForwardHeader | |
| FRAG |
Fragmentation layer.
|
| FRAG2 |
Fragmentation layer.
|
| FRAG2.FragEntry |
Class represents an entry for a message.
|
| FragHeader | |
| GOOGLE_PING |
Discovery protocol for Google Cloud Storage.
|
| HDRS |
Prints the headers of all sent or received messages
|
| JDBC_PING |
Discovery protocol using a JDBC connection to a shared database.
|
| KeyExchange |
Base class for protocols implementing key exchange: a secret key to be used for encryption is exchanged between
2 parties (usually the key server and a new cluster member) securely; ie.
|
| Locking |
Base locking protocol, handling most of the protocol communication with other instances.
|
| Locking.LockingHeader | |
| Locking.Request | |
| Locking.Response |
A response to a request, to be sent back to the requester as a message
|
| MAKE_BATCH |
Intercepts individual up messages and creates batches from them, passing the batches up.
|
| MERGE2 | Deprecated
Use
MERGE3 instead, as it causes less traffic, especially for large clusters |
| MERGE2.MergeHeader | |
| MERGE3 |
Protocol to discover subgroups; e.g., existing due to a network partition (that healed).
|
| MERGE3.MergeHeader | |
| MFC |
Simple flow control protocol based on a credit system.
|
| MPING |
Uses its own IP multicast socket to send and receive discovery requests/responses.
|
| NoBundler |
Bundler which doesn't bundle :-) Can be used to measure the diff between bundling and non-bundling (e.g.
|
| PDC |
Persistent Discovery Cache.
|
| PDC.Mapping | |
| PEER_LOCK | Deprecated
Use
CENTRAL_LOCK instead |
| PERF |
Protocol measuring latency between stacks.
|
| PERF.PerfHeader | |
| PING |
The PING protocol retrieves the initial membership by mcasting a discovery request (via the multicast capable
transport) to all current cluster members
The responses should allow us to determine the coordinator which we have to contact, e.g.
|
| PingData |
Encapsulates information about a cluster node, e.g.
|
| PingHeader | |
| PRIO |
This protocol will provide message sending and receiving prioritization.
|
| PRIO.PriorityMessage |
This class is a simple wrapper to contain the Event, timestamp and priority of the message.
|
| 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);
|
| RACKSPACE_PING |
Discovery protocol based on Rackspace Cloud Files storage solution
|
| RATE_LIMITER |
Protocol which sends at most max_bytes in time_period milliseconds.
|
| RELAY |
Simple relaying protocol: RELAY is added to the top of the stack, creates a channel to a bridge cluster,
and - if coordinator - relays all multicast messages via the bridge cluster to the remote cluster.
This is not a big virtual cluster, e.g.
|
| RELAY.RelayHeader | |
| RELAY.ViewData |
Contains local and remote views, and UUID information
|
| RingBufferBundler |
Bundler which uses
RingBuffer to store messages. |
| RingBufferBundlerLockless |
Bundler which doesn't use locks but relies on CAS.
|
| RingBufferBundlerLockless2 |
Lockless bundler using a reader thread which is unparked by (exactly one) writer thread.
|
| RSVP |
Protocol which implements synchronous messages (https://issues.jboss.org/browse/JGRP-1389).
|
| RSVP.Entry | |
| RSVP.RsvpHeader | |
| S3_PING |
Discovery protocol using Amazon's S3 storage.
|
| SASL |
The SASL protocol implements authentication and, if requested by the mech, encryption
|
| SaslHeader | |
| SCOPE | Deprecated
Use the async invocation API instead:
http://www.jgroups.org/manual-3.x/html/user-building-blocks.html#AsyncInvocation
|
| SCOPE.MessageQueue | |
| SCOPE.ScopeHeader | |
| SenderSendsBundler | |
| SenderSendsWithTimerBundler | Deprecated |
| SEQUENCER |
Implementation of total order protocol using a sequencer.
|
| SEQUENCER.SequencerHeader | |
| SEQUENCER2 |
Implementation of total order protocol using a sequencer_uum.
|
| SEQUENCER2.SequencerHeader | |
| SHARED_LOOPBACK |
Loopback transport shared by all channels within the same VM.
|
| SHARED_LOOPBACK_PING |
Discovery protocol running over
SHARED_LOOPBACK only. |
| SHUFFLE |
Reorders messages by buffering them and shuffling the result after TIMEOUT ms.
|
| SimplifiedTransferQueueBundler |
This bundler uses the same logic as
TransferQueueBundler but does not allocate
memory except for the buffer itself and does not use complex data structures. |
| SIZE |
Protocol which prints out the real size of a message.
|
| SSL_KEY_EXCHANGE |
Key exchange based on SSL sockets.
|
| STATS |
Provides various stats
|
| STOMP |
Protocol which provides STOMP (http://stomp.codehaus.org/) support.
|
| STOMP.Frame | |
| STOMP.StompHeader | |
| SWIFT_PING |
Discovery protocol based on Openstack Swift (object storage).
|
| SWIFT_PING.SwiftClient |
A thread safe Swift client
|
| SYM_ENCRYPT |
Encrypts and decrypts communication in JGroups by using a secret key shared by all cluster members.
|
| TCP |
TCP based protocol.
|
| TCP_NIO | Deprecated |
| TCP_NIO2 |
Protocol using TCP/IP to send and receive messages.
|
| TCPGOSSIP |
The TCPGOSSIP protocol layer retrieves the initial membership (used by the
GMS when started by sending event FIND_INITIAL_MBRS down the stack).
|
| TCPPING |
The TCPPING protocol defines a static cluster membership.
|
| TP |
Generic transport - specific implementations should extend this abstract class.
|
| TP.ProtocolAdapter |
Used when the transport is shared (singleton_name != null).
|
| TpHeader |
Generic transport header, used by TP.
|
| TRACE | |
| TransferQueueBundler |
This bundler adds all (unicast or multicast) messages to a queue until max size has been exceeded, but does send
messages immediately when no other messages are available.
|
| TUNNEL |
Replacement for UDP.
|
| UDP |
IP multicast transport based on UDP.
|
| UFC |
Simple flow control protocol based on a credit system.
|
| UNICAST | Deprecated
Will be removed in 4.0
|
| UNICAST.ReceiverEntry | |
| UNICAST.UnicastHeader |
The following types and fields are serialized:
|
| UNICAST2 | Deprecated
Will be removed in 4.0
|
| UNICAST2.Unicast2Header |
The following types and fields are serialized:
|
| UNICAST3 |
Reliable unicast protocol using a combination of positive and negative acks.
|
| UNICAST3.Header |
The following types and fields are serialized:
|
| VERIFY_SUSPECT |
Catches SUSPECT events traveling up the stack.
|
| VERIFY_SUSPECT.VerifyHeader |
Copyright © 1998-2020 Red Hat. All Rights Reserved.