Uses of Class
org.jgroups.stack.Protocol
Packages that use Protocol
Package
Description
Provides debug support, including testing, profiling, and a graphical view of a protocol stack.
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
Supports probabilistic broadcasts.
Support for managing protocol stacks.
-
Uses of Protocol in org.jgroups.debug
Methods in org.jgroups.debug that return ProtocolMethods in org.jgroups.debug that return types with arguments of type ProtocolMethods in org.jgroups.debug with parameters of type ProtocolConstructors in org.jgroups.debug with parameters of type Protocol -
Uses of Protocol in org.jgroups.jmx
Methods in org.jgroups.jmx with parameters of type ProtocolModifier and TypeMethodDescriptionJmxConfigurator.asDynamicMBean(Protocol p) Deprecated.static DynamicMBeanWrap Protocol with DynamicMBean interface. -
Uses of Protocol in org.jgroups.protocols
Subclasses of Protocol in org.jgroups.protocolsModifier and TypeClassDescriptionclassThe AUTH protocol adds a layer of authentication to JGroupsclassAll messages up the stack have to go through a barrier (read lock, RL).classShared base class for tcpip protocolsclassBroadcast PING.classBeanshell (www.beanshell.org) interpreter class.classThis is a central executor service where each request is sent to the coordinator for either a task or a current waiting thread.classImplementation of a locking protocol which acquires locks by contacting the coordinator.classCompresses the payload of a message.classImplementation of daisy chaining.classDelays incoming/outgoing messages by a random number of milliseconds (range between 0 and n where n is determined by the user).classDiscards 2 JOIN-REQs then accepts 1, then discards 2 more and so onclassDiscards 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.classDiscards a message whose sequence number (in the payload, as a Long) matches seqno 2 times, before passing it down.classThe Discovery protocol layer retrieves the initial membership (used by the GMS when started by sending event FIND_INITIAL_MBRS down the stack).classDuplicates outgoing or incoming messages by copying themclassENCRYPT layer.classExample of a protocol layer.classThis is the base protocol used for executions.classSimple flow control protocol based on a credit system.classFailure detection based on simple heartbeat protocol.classFailure detection based on simple heartbeat protocol.classProtocol 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.classProtocol which uses an executable (e.g.classSimple failure detection protocol.classFailure detection protocol based on sockets.classSimple discovery protocol which uses a file on shared storage such as an SMB share, NFS mount or S3.classSimple flow control protocol based on a credit system.classFragmentation layer.classFragmentation layer.classExample of a protocol layer.classImplementation of UTO-TCP as designed by EPFL.classDiscovery protocol using a JDBC connection to a shared database.classBase locking protocol, handling most of the protocol communication with other instances.classMakes copies of outgoing messages, swaps sender and receiver and sends the message back up the stack.classProtocol to discover subgroups; e.g., existing due to a network partition (that healed).classProtocol to discover subgroups; e.g., existing due to a network partition (that healed).classThe coordinator attaches a small header with its view to each (or every nth) message.classSimple flow control protocol based on a credit system.classUses its own IP multicast socket to send and receive discovery requests/responses.classImplementation of a locking protocol which acquires locks by contacting all of the nodes of a cluster.classMeasures the time for a message to travel from the channel to the transportclassThe PING protocol layer retrieves the initial membership (used by the GMS when started by sending event FIND_INITIAL_MBRS down the stack).classThis protocol will provide message sending and receiving prioritization.classProtocol which sends at most max_bytes in time_period milliseconds.classSimple 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.classDiscovery protocol using Amazon's S3 storage.classImplements https://jira.jboss.org/jira/browse/JGRP-822, which allows for concurrent delivery of messages from the same sender based on scopes.classImplementation of total order protocol using a sequencer.classDeprecated.classLoopback transport shared by all channels within the same VM.classReorders messages by buffering them and shuffling the result after TIMEOUT ms.classProtocol which prints out the real size of a message.classSimple Multicast ACK protocol.classProvides various statsclassProtocol which provides STOMP (http://stomp.codehaus.org/) support.classTCP based protocol.classTransport using NIOclassThe TCPGOSSIP protocol layer retrieves the initial membership (used by the GMS when started by sending event FIND_INITIAL_MBRS down the stack).classThe TCPPING protocol layer retrieves the initial membership in answer to the GMS's FIND_INITIAL_MBRS event.classGeneric transport - specific implementations should extend this abstract class.static classUsed when the transport is shared (singleton_name is not null).classclassReplacement for UDP.classIP multicast transport based on UDP.classSimple flow control protocol based on a credit system.classReliable unicast layer.classReliable unicast layer.classCatches SUSPECT events traveling up the stack.classPeriodically sends the view to the group.Fields in org.jgroups.protocols with type parameters of type ProtocolModifier and TypeFieldDescriptionprotected final ConcurrentMap<String, Protocol> TP.up_protsIf 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).Methods in org.jgroups.protocols that return types with arguments of type ProtocolConstructors in org.jgroups.protocols with parameters of type Protocol -
Uses of Protocol in org.jgroups.protocols.pbcast
Subclasses of Protocol in org.jgroups.protocols.pbcastModifier and TypeClassDescriptionclassFlush, as it name implies, forces group members to flush their pending messages while blocking them to send any additional messages.classGroup membership protocol.classNegative AcKnowledgement layer (NAKs).classComputes the broadcast messages that are stable; i.e., have been received by all members.classSTATE_TRANSFER protocol based on byte array transfer.classSTREAMING_STATE_TRANSFER, as its name implies, allows a streaming state transfer between two channel instances. -
Uses of Protocol in org.jgroups.stack
Subclasses of Protocol in org.jgroups.stackModifier and TypeClassDescriptionclassA ProtocolStack manages a number of protocols layered above each other.Fields in org.jgroups.stack declared as ProtocolModifier and TypeFieldDescriptionprotected ProtocolProtocol.down_protprotected ProtocolProtocol.up_protMethods in org.jgroups.stack that return ProtocolModifier and TypeMethodDescriptionstatic ProtocolConfigurator.connectProtocols(List<Protocol> protocol_list) Creates a protocol stack by iterating through the protocol list and connecting adjacent layers.protected static ProtocolConfigurator.createLayer(ProtocolStack stack, ProtocolConfiguration config) static ProtocolConfigurator.createProtocol(String prot_spec, ProtocolStack stack) Creates a new protocol given the protocol specification.protected ProtocolProtocolStack.createProtocol(String classname) ProtocolStack.findProtocol(Class<?> clazz) ProtocolStack.findProtocol(Class<?>... classes) Finds the first protocol of a list and returns it.ProtocolStack.findProtocol(String name) Returns a given protocol or null if not foundProtocolStack.getBottomProtocol()Protocol.getDownProtocol()ProtocolStack.getTopProtocol()Protocol.getUpProtocol()ProtocolStack.removeProtocol(Class prot) ProtocolStack.removeProtocol(Class... protocols) ProtocolStack.removeProtocol(String prot_name) Removes a protocol from the stack.Configurator.setupProtocolStack(List<ProtocolConfiguration> config) Configurator.setupProtocolStack(ProtocolStack copySource) Methods in org.jgroups.stack that return types with arguments of type ProtocolModifier and TypeMethodDescriptionProtocolStack.copyProtocols(ProtocolStack targetStack) ProtocolStack.getProtocols()Returns all protocols in a list, from top to bottom.Methods in org.jgroups.stack with parameters of type ProtocolModifier and TypeMethodDescriptionProtocolStack.addProtocol(Protocol prot) Adds a protocol at the tail of the protocol listProtocolStack.addProtocols(Protocol... prots) Adds a list of protocolsstatic RouterStubManagerRouterStubManager.emptyGossipClientStubManager(Protocol p) static ObjectConfigurator.getValueFromProtocol(Protocol protocol, Field field) static ObjectConfigurator.getValueFromProtocol(Protocol protocol, String field_name) voidProtocolStack.insertProtocol(Protocol prot, int position, Class<? extends Protocol> neighbor_prot) voidProtocolStack.insertProtocol(Protocol prot, int position, Class<? extends Protocol>... neighbor_prots) voidProtocolStack.insertProtocol(Protocol prot, int position, String neighbor_prot) Inserts an already created (and initialized) protocol into the protocol list.voidProtocolStack.insertProtocolAtTop(Protocol prot) voidProtocolStack.insertProtocolInStack(Protocol prot, Protocol neighbor, int position) voidProtocol.setDownProtocol(Protocol down_prot) voidProtocol.setUpProtocol(Protocol up_prot) Method parameters in org.jgroups.stack with type arguments of type ProtocolModifier and TypeMethodDescriptionProtocolStack.addProtocols(List<Protocol> prots) Adds a list of protocolsstatic ProtocolConfigurator.connectProtocols(List<Protocol> protocol_list) Creates a protocol stack by iterating through the protocol list and connecting adjacent layers.static voidConfigurator.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 interfacestatic List<InetAddress> Configurator.getInetAddresses(List<Protocol> protocols) voidProtocolStack.insertProtocol(Protocol prot, int position, Class<? extends Protocol> neighbor_prot) static voidConfigurator.sanityCheck(List<Protocol> protocols) Throws an exception if sanity check fails.static voidConfigurator.setDefaultValues(List<Protocol> protocols) static voidConfigurator.setDefaultValues(List<Protocol> protocols, StackType ip_version) Constructors in org.jgroups.stack with parameters of type ProtocolModifierConstructorDescriptionRouterStubManager(Protocol owner, String channelName, Address logicalAddress, long interval)