Package | Description |
---|---|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.blocks.mux | |
org.jgroups.jmx | |
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.stack |
Support for managing protocol stacks.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Field and Description |
---|---|
protected Protocol |
RequestCorrelator.transport
The protocol layer to use to pass up/down messages.
|
Modifier and Type | Method and Description |
---|---|
protected RequestCorrelator |
MessageDispatcher.createRequestCorrelator(Protocol transport,
RequestHandler handler,
Address local_addr) |
Constructor and Description |
---|
RequestCorrelator(Protocol transport,
RequestHandler handler,
Address local_addr) |
RequestCorrelator(short id,
Protocol transport,
RequestHandler handler,
Address local_addr)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected RequestCorrelator |
MuxRpcDispatcher.createRequestCorrelator(Protocol transport,
RequestHandler handler,
Address localAddr) |
protected RequestCorrelator |
MuxMessageDispatcher.createRequestCorrelator(Protocol transport,
RequestHandler handler,
Address localAddr) |
Constructor and Description |
---|
MuxRequestCorrelator(short id,
Protocol transport,
RequestHandler handler,
Address localAddr) |
Modifier and Type | Method and Description |
---|---|
static DynamicMBean |
JmxConfigurator.wrap(Protocol p)
Wrap Protocol with DynamicMBean interface.
|
Modifier and Type | Class and Description |
---|---|
class |
AUTH
The AUTH protocol adds a layer of authentication to JGroups
|
class |
BARRIER
All messages up the stack have to go through a barrier (read lock, RL).
|
class |
BasicTCP
Shared base class for TCP protocols
|
class |
BPING
Broadcast PING.
|
class |
BSH
Beanshell (www.beanshell.org) interpreter class.
|
class |
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.
|
class |
CENTRAL_LOCK
Implementation of a locking protocol which acquires locks by contacting the coordinator.
|
class |
COMPRESS
Compresses the payload of a message.
|
class |
COUNTER
Protocol which is used by
CounterService to provide a distributed atomic counter |
class |
DAISYCHAIN
Implementation of daisy chaining.
|
class |
DELAY
Delays incoming/outgoing messages by a random number of milliseconds (range between 0 and n
where n is determined by the user).
|
class |
DELAY_JOIN_REQ
Discards 2 JOIN-REQs then accepts 1, then discards 2 more and so on
|
class |
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.
|
class |
DISCARD_PAYLOAD
Discards a message whose sequence number (in the payload, as a Long) matches seqno 2 times,
before passing it down.
|
class |
Discovery
The Discovery protocol retrieves the initial membership (used by GMS and MERGE2) by sending discovery requests.
|
class |
DUPL
Duplicates outgoing or incoming messages by copying them
|
class |
ENCRYPT
ENCRYPT layer.
|
class |
EXAMPLE
Example of a protocol layer.
|
class |
Executing
This is the base protocol used for executions.
|
class |
FC
Simple flow control protocol based on a credit system.
|
class |
FD
Failure detection based on simple heartbeat protocol.
|
class |
FD_ALL
Failure detection based on simple heartbeat protocol.
|
class |
FD_ICMP
Protocol which uses InetAddress.isReachable() to check whether a given host
is up or not, taking 1 argument; the host name of the host to be pinged.
|
class |
FD_PING
Protocol which uses an executable (e.g.
|
class |
FD_SIMPLE
Simple failure detection protocol.
|
class |
FD_SOCK
Failure detection protocol based on sockets.
|
class |
FILE_PING
Simple discovery protocol which uses a file on shared storage such as an SMB share, NFS mount or S3.
|
class |
FlowControl
Simple flow control protocol based on a credit system.
|
class |
FRAG
Fragmentation layer.
|
class |
FRAG2
Fragmentation layer.
|
class |
HDRS
Example of a protocol layer.
|
class |
HTOTAL
Implementation of UTO-TCP as designed by EPFL.
|
class |
JDBC_PING
Discovery protocol using a JDBC connection to a shared database.
|
class |
Locking
Base locking protocol, handling most of the protocol communication with other instances.
|
class |
MERGE2
Protocol to discover subgroups; e.g., existing due to a network partition (that healed).
|
class |
MFC
Simple flow control protocol based on a credit system.
|
class |
MPING
Uses its own IP multicast socket to send and receive discovery requests/responses.
|
class |
PEER_LOCK
Implementation of a locking protocol which acquires locks by contacting all of the nodes of a cluster.
|
class |
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.
|
class |
PRIO
This protocol will provide message sending and receiving prioritization.
|
class |
RATE_LIMITER
Protocol which sends at most max_bytes in time_period milliseconds.
|
class |
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.
|
class |
RSVP
Protocol which implements synchronous messages (https://issues.jboss.org/browse/JGRP-1389).
|
class |
S3_PING
Discovery protocol using Amazon's S3 storage.
|
class |
SCOPE
Implements https://jira.jboss.org/jira/browse/JGRP-822, which allows for concurrent delivery of messages from the
same sender based on scopes.
|
class |
SEQUENCER
Implementation of total order protocol using a sequencer.
|
class |
SHARED_LOOPBACK
Loopback transport shared by all channels within the same VM.
|
class |
SHUFFLE
Reorders messages by buffering them and shuffling the result after TIMEOUT ms.
|
class |
SIZE
Protocol which prints out the real size of a message.
|
class |
STATS
Provides various stats
|
class |
STOMP
Protocol which provides STOMP (http://stomp.codehaus.org/) support.
|
class |
TCP
TCP based protocol.
|
class |
TCP_NIO
Transport using NIO
|
class |
TCPGOSSIP
The TCPGOSSIP protocol layer retrieves the initial membership (used by the
GMS when started by sending event FIND_INITIAL_MBRS down the stack).
|
class |
TCPPING
The TCPPING protocol defines a static cluster membership.
|
class |
TP
Generic transport - specific implementations should extend this abstract class.
|
static class |
TP.ProtocolAdapter
Used when the transport is shared (singleton_name is not null).
|
class |
TRACE |
class |
TUNNEL
Replacement for UDP.
|
class |
UDP
IP multicast transport based on UDP.
|
class |
UFC
Simple flow control protocol based on a credit system.
|
class |
UNICAST
Reliable unicast layer.
|
class |
UNICAST2
Reliable unicast layer.
|
class |
VERIFY_SUSPECT
Catches SUSPECT events traveling up the stack.
|
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<String,Protocol> |
TP.up_prots
If singleton_name is enabled, this map is used to de-multiplex incoming messages according to their cluster
names (attached to the message by the transport anyway).
|
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<String,Protocol> |
TP.getUpProtocols() |
Constructor and Description |
---|
TP.ProtocolAdapter(String cluster_name,
Address local_addr,
short transport_id,
Protocol up,
Protocol down,
String pattern) |
Modifier and Type | Class and Description |
---|---|
class |
FLUSH
Flush, as it name implies, forces group members to flush their pending messages while blocking
them to send any additional messages.
|
class |
GMS
Group membership protocol.
|
class |
NAKACK
Negative AcKnowledgement layer (NAKs).
|
class |
STABLE
Computes the broadcast messages that are stable; i.e., have been received by
all members.
|
class |
STATE
STATE streams the state (written to an OutputStream) to the state requester in chunks (defined by
chunk_size).
|
class |
STATE_SOCK
STATE_SOCK has the state provider create a server socket to which the state
requester connects and from which the latter reads the state. |
class |
STATE_TRANSFER
STATE_TRANSFER protocol based on byte array transfer.
|
class |
StreamingStateTransfer
Base class for state transfer protocols which use streaming (or chunking) to transfer state between two members.
|
Modifier and Type | Class and Description |
---|---|
class |
ProtocolStack
A ProtocolStack manages a number of protocols layered above each other.
|
Modifier and Type | Field and Description |
---|---|
protected Protocol |
Protocol.down_prot |
protected Protocol |
Protocol.up_prot |
Modifier and Type | Method and Description |
---|---|
static Protocol |
Configurator.connectProtocols(List<Protocol> protocol_list)
Creates a protocol stack by iterating through the protocol list and connecting
adjacent layers.
|
protected static Protocol |
Configurator.createLayer(ProtocolStack stack,
ProtocolConfiguration config) |
protected Protocol |
ProtocolStack.createProtocol(String classname) |
static Protocol |
Configurator.createProtocol(String prot_spec,
ProtocolStack stack)
Creates a new protocol given the protocol specification.
|
Protocol |
ProtocolStack.findProtocol(Class<?>... classes)
Finds the first protocol of a list and returns it.
|
Protocol |
ProtocolStack.findProtocol(Class<?> clazz) |
Protocol |
ProtocolStack.findProtocol(String name)
Returns a given protocol or null if not found
|
Protocol |
ProtocolStack.getBottomProtocol() |
Protocol |
Protocol.getDownProtocol() |
Protocol |
ProtocolStack.getTopProtocol() |
Protocol |
Protocol.getUpProtocol() |
Protocol |
ProtocolStack.removeProtocol(Class... protocols) |
Protocol |
ProtocolStack.removeProtocol(Class prot) |
Protocol |
ProtocolStack.removeProtocol(String prot_name)
Removes a protocol from the stack.
|
Protocol |
Configurator.setupProtocolStack(List<ProtocolConfiguration> config) |
Protocol |
Configurator.setupProtocolStack(ProtocolStack copySource) |
Protocol |
Protocol.setValue(String name,
Object value) |
Protocol |
Protocol.setValues(Map<String,Object> values) |
Modifier and Type | Method and Description |
---|---|
List<Protocol> |
ProtocolStack.copyProtocols(ProtocolStack targetStack) |
List<Protocol> |
ProtocolStack.getProtocols()
Returns all protocols in a list, from top to bottom.
|
Modifier and Type | Method and Description |
---|---|
ProtocolStack |
ProtocolStack.addProtocol(Protocol prot)
Adds a protocol at the tail of the protocol list
|
ProtocolStack |
ProtocolStack.addProtocols(Protocol... prots)
Adds a list of protocols
|
static RouterStubManager |
RouterStubManager.emptyGossipClientStubManager(Protocol p) |
static Object |
Configurator.getValueFromProtocol(Protocol protocol,
Field field) |
static Object |
Configurator.getValueFromProtocol(Protocol protocol,
String field_name) |
void |
ProtocolStack.insertProtocol(Protocol prot,
int position,
Class<? extends Protocol>... neighbor_prots) |
void |
ProtocolStack.insertProtocol(Protocol prot,
int position,
Class<? extends Protocol> neighbor_prot) |
void |
ProtocolStack.insertProtocol(Protocol prot,
int position,
String neighbor_prot)
Inserts an already created (and initialized) protocol into the protocol list.
|
void |
ProtocolStack.insertProtocolAtTop(Protocol prot) |
void |
ProtocolStack.insertProtocolInStack(Protocol prot,
Protocol neighbor,
int position) |
protected static void |
Configurator.removeProvidedDownServices(Protocol protocol,
List<Integer> events)
Removes all events provided by the protocol above protocol from events
|
protected static void |
Configurator.removeProvidedUpServices(Protocol protocol,
List<Integer> events)
Removes all events provided by the protocol below protocol from events
|
void |
ProtocolStack.replaceProtocol(Protocol existing_prot,
Protocol new_prot)
Replaces one protocol instance with another.
|
void |
Protocol.setDownProtocol(Protocol down_prot) |
void |
Protocol.setUpProtocol(Protocol up_prot) |
Modifier and Type | Method and Description |
---|---|
ProtocolStack |
ProtocolStack.addProtocols(List<Protocol> prots)
Adds a list of protocols
|
static Protocol |
Configurator.connectProtocols(List<Protocol> protocol_list)
Creates a protocol stack by iterating through the protocol list and connecting
adjacent layers.
|
static Map<String,Map<String,Configurator.InetAddressInfo>> |
Configurator.createInetAddressMap(List<ProtocolConfiguration> protocol_configs,
List<Protocol> protocols) |
static void |
Configurator.ensureValidBindAddresses(List<Protocol> protocols)
Makes sure that all fields annotated with @LocalAddress is (1) an InetAddress and (2) a valid address on any
local network interface
|
static List<InetAddress> |
Configurator.getInetAddresses(List<Protocol> protocols) |
void |
ProtocolStack.insertProtocol(Protocol prot,
int position,
Class<? extends Protocol> neighbor_prot) |
static void |
Configurator.sanityCheck(List<Protocol> protocols)
Throws an exception if sanity check fails.
|
static void |
Configurator.setDefaultValues(List<Protocol> protocols) |
static void |
Configurator.setDefaultValues(List<Protocol> protocols,
StackType ip_version) |
static void |
Configurator.setDefaultValues(List<ProtocolConfiguration> protocol_configs,
List<Protocol> protocols,
StackType ip_version) |
Constructor and Description |
---|
RouterStubManager(Protocol owner,
String channelName,
Address logicalAddress,
long interval) |
Modifier and Type | Method and Description |
---|---|
static JChannel |
Util.createChannel(Protocol... prots) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.