Uses of Class
org.jgroups.stack.Protocol
-
Packages that use Protocol Package Description org.jgroups Provides top-level public JGroups classes such as Channel, Message, etc.org.jgroups.blocks Provides building blocks that are layered on top of channels.org.jgroups.conf Provides ways to configure a protocol stack.org.jgroups.fork 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.dns org.jgroups.protocols.pbcast org.jgroups.protocols.relay org.jgroups.protocols.relay.config org.jgroups.stack Support for managing protocol stacks.org.jgroups.util Provides useful functionality which cannot be assigned to any particular other package. -
-
Uses of Protocol in org.jgroups
Methods in org.jgroups with parameters of type Protocol Modifier and Type Method Description protected java.lang.reflect.MethodJChannelProbeHandler. findMethod(Protocol prot, java.lang.String method_name, java.lang.String[] args)Constructors in org.jgroups with parameters of type Protocol Constructor Description JChannel(Protocol... protocols)Creates a channel from an array of protocols.Constructor parameters in org.jgroups with type arguments of type Protocol Constructor Description JChannel(java.util.List<Protocol> protocols)Creates a channel from a list of protocols. -
Uses of Protocol in org.jgroups.blocks
Subclasses of Protocol in org.jgroups.blocks Modifier and Type Class Description protected classMessageDispatcher.ProtocolAdapterFields in org.jgroups.blocks declared as Protocol Modifier and Type Field Description protected ProtocolRequestCorrelator. down_protThe protocol layer to use to pass up/down messages.Methods in org.jgroups.blocks with type parameters of type Protocol Modifier and Type Method Description <T extends Protocol>
TMessageDispatcher.ProtocolAdapter. setAddress(Address addr)<T extends Protocol>
TMessageDispatcher.ProtocolAdapter. setDownProt(Protocol d)Methods in org.jgroups.blocks with parameters of type Protocol Modifier and Type Method Description protected static RequestCorrelatorMessageDispatcher. createRequestCorrelator(Protocol transport, RequestHandler handler, Address local_addr)<T extends Protocol>
TMessageDispatcher.ProtocolAdapter. setDownProt(Protocol d)Constructors in org.jgroups.blocks with parameters of type Protocol Constructor Description RequestCorrelator(Protocol down_prot, RequestHandler handler, Address local_addr)Constructor. -
Uses of Protocol in org.jgroups.conf
Methods in org.jgroups.conf that return types with arguments of type Protocol Modifier and Type Method Description java.lang.Class<? extends Protocol>ProtocolConfiguration. loadProtocolClass(java.lang.Class<?> loadingClass)Load the class of theProtocolconfigured by this instance.Methods in org.jgroups.conf with parameters of type Protocol Modifier and Type Method Description default voidProtocolStackConfigurator. afterCreation(Protocol prot)Method parameters in org.jgroups.conf with type arguments of type Protocol Modifier and Type Method Description booleanProtocolConfiguration. isAssignableProtocol(java.lang.Class<? extends Protocol> other, java.lang.Class<?> loadingClass)Determines if the classotheris the same or superclass (or superinterface) as theProtocolconfigured by this instance. -
Uses of Protocol in org.jgroups.fork
Subclasses of Protocol in org.jgroups.fork Modifier and Type Class Description classForkProtocolActs as bottom protocol of a fork-stack.classForkProtocolStackProtocol stack which maintains the mapping between fork-channel IDs and ForkChannelsFields in org.jgroups.fork with type parameters of type Protocol Modifier and Type Field Description protected java.util.List<Protocol>ForkProtocolStack. protocolsMethods in org.jgroups.fork that return types with arguments of type Protocol Modifier and Type Method Description java.util.List<Protocol>ForkProtocolStack. getProtocols()Method parameters in org.jgroups.fork with type arguments of type Protocol Modifier and Type Method Description protected static FORKForkChannel. getFORK(JChannel ch, ProtocolStack.Position position, java.lang.Class<? extends Protocol> neighbor, boolean create_fork_if_absent)Creates a new FORK protocol, or returns the existing one, or throws an exception.Constructors in org.jgroups.fork with parameters of type Protocol Constructor Description ForkChannel(JChannel main_channel, java.lang.String fork_stack_id, java.lang.String fork_channel_id, boolean create_fork_if_absent, ProtocolStack.Position position, java.lang.Class<? extends Protocol> neighbor, Protocol... protocols)Creates a new fork-channel from a main-channel.ForkChannel(JChannel main_channel, java.lang.String fork_stack_id, java.lang.String fork_channel_id, Protocol... protocols)Creates a new fork-channel from a main-channel.Constructor parameters in org.jgroups.fork with type arguments of type Protocol Constructor Description ForkChannel(JChannel main_channel, java.lang.String fork_stack_id, java.lang.String fork_channel_id, boolean create_fork_if_absent, ProtocolStack.Position position, java.lang.Class<? extends Protocol> neighbor, Protocol... protocols)Creates a new fork-channel from a main-channel.ForkProtocolStack(UnknownForkHandler unknownForkHandler, java.util.List<Protocol> protocols, java.lang.String fork_stack_id) -
Uses of Protocol in org.jgroups.jmx
Methods in org.jgroups.jmx with parameters of type Protocol Modifier and Type Method Description static javax.management.DynamicMBeanJmxConfigurator. wrap(Protocol p)Wrap Protocol with DynamicMBean interface. -
Uses of Protocol in org.jgroups.protocols
Subclasses of Protocol in org.jgroups.protocols Modifier and Type Class Description classASYM_ENCRYPTEncrypts 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.classASYNCDelivers message batches in separate threads.classAUTHThe AUTH protocol adds a layer of authentication to JGroups.classBARRIERAll messages up the stack have to go through a barrier (read lock, RL).classBasicTCPShared base class for TCP protocolsclassBATCHDeprecated, for removal: This API element is subject to removal in a future version.classBATCH2Batches messages near the top of the stack.classBPINGBroadcast PING.classCLEAR_FLAGSProtocol which clears a set of flags in the down or up direction for all messagesclassCOMPRESSCompresses the payload of a message.classCOUNTERProtocol which is used byCounterServiceto provide a distributed atomic counterclassDAISYCHAINImplementation of daisy chaining.classDELAYDelays 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).classDETECT_LOOPBACKSDetects unicast loopbacks: messages where dest == local addressclassDH_KEY_EXCHANGEKey exchange based on Diffie-Hellman-Merkle (https://en.wikipedia.org/wiki/Diffie%E2%80%93Hellman_key_exchange).
Diffie-Hellman is used between a member and a key server (the coordinator) to obtain a session key (only known to the key server and the joiner) which is used by the key server to encrypt the shared secret symmetric (group) key and by the requester to decrypt the group key it gets in the response of the key server.classDISCARDDiscards 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.classDISCARD_PAYLOADDiscards a message whose sequence number (in the payload, as a Long) matches seqno 2 times, before passing it down.classDiscoveryThe Discovery protocol retrieves the initial membership (used by GMS and MERGE3) by sending discovery requests.classDROPProtocol which drops up or down messages according to user-defined filtersclassDUPLDuplicates outgoing or incoming messages by copying themclassEncrypt<E extends java.security.KeyStore.Entry>Super class of symmetric (SYM_ENCRYPT) and asymmetric (ASYM_ENCRYPT) encryption protocols.classEXAMPLEExample of a protocol layer.classFailureDetectionclassFD_ALLFailure detection based on simple heartbeat protocol.classFD_ALL2Failure detection based on simple heartbeat protocol.classFD_ALL3Failure detection based on simple heartbeat protocol.classFD_HOSTFailure detection protocol which detects the crash or hanging of entire hosts and suspects all cluster members on those hosts.classFD_SOCKFailure detection protocol based on sockets.classFD_SOCK2Failure detection protocol based on TCP connections, successor toFD_SOCK.classFILE_PINGSimple discovery protocol which uses a file on shared storage such as an SMB share, NFS mount or S3.classFlowControlSimple flow control protocol based on a credit system.classFORKThe FORK protocol; multiplexes messages to different forks in a stack (https://issues.redhat.com/browse/JGRP-1613).classFRAGFragmentation layer.classFRAG2Fragmentation layer.classFRAG3Fragmentation protocol which uses less memory to store fragments thanFRAG2.
When a message is fragmented, all fragments carry the size of the original message, their offset and length with respect to the original message and a fragment ID (to identify the fragment).
When the first fragment is received, the full message is created and each fragment copies its data into the full message at its offset and length.classFRAG4Fragmentation layer.classFragmentationBase class for all fragmentation protocols.classHDRSPrints the headers of all sent or received messagesclassINJECT_VIEWSimple protocol to inject an arbitrary view on one or more cluster nodes.classJDBC_PINGDiscovery protocol using a JDBC connection to a shared database.classJDBC_PING2New version ofJDBC_PING.classKeyExchangeBase 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.classLOCAL_PINGDiscovery protocol for finding members in the local process only.classMAKE_BATCHIntercepts individual up messages and creates batches from them, passing the batches up.classMERGE3Protocol to discover subgroups; e.g., existing due to a network partition (that healed).classMFCSimple flow control protocol based on a credit system.classMFC_NBNon-blocking alternative toMFC.
JIRA: JIRA: https://issues.redhat.com/browse/JGRP-2172classMPINGUses its own IP multicast socket to send and receive discovery requests/responses.classNAKACK3Negative AcKnowledgement layer (NAKs).classNAKACK4New multicast protocol based on fixed-size xmit windows and message ACKs
Details: https://issues.redhat.com/browse/JGRP-2780classNON_BLOCKING_SENDSDetects sends during processing of incoming messages and sets flagMessage.TransientFlag.DONT_BLOCKto prevent blocking the incoming thread on a send.
JIRA: https://issues.redhat.com/browse/JGRP-2772classPDCPersistent Discovery Cache.classPERFProtocol measuring latency between stacks.classPINGThe PING protocol retrieves the initial membership by mcasting a discovery request (via the multicast capable transport) to all current cluster membersclassRACKSPACE_PINGDiscovery protocol based on Rackspace Cloud Files storage solutionclassRATEMeasures incoming and outgoing rates: messages/sec, bytes/sec.classRATE_LIMITERProtocol which sends at most max_bytes in time_period milliseconds.classRATE_LIMITER2Rate limiter based credits (max_bytes).classREDImplementation of Random Early Drop: messages are discarded when the bundler's queue in the transport nears exhaustion.classReliableMulticastBase class for reliable multicast protocolsclassReliableUnicastBase class for reliable unicast protocolsclassREVERSEReverses the next N messages that are received.classREVERSE2classRSVPProtocol which implements synchronous messages (https://issues.redhat.com/browse/JGRP-1389).classSEQUENCERImplementation of total order protocol using a sequencer.classSEQUENCER2Implementation of total order protocol using a sequencer_uum.classSERIALIZESerializes the entire message (including payload, headers, flags and destination and src) into the payload of another message that's then sent.classSHARED_LOOPBACKLoopback transport shared by all channels within the same VM.classSHARED_LOOPBACK_PINGDiscovery protocol running overSHARED_LOOPBACKonly.classSHUFFLEReorders messages by buffering them and shuffling the result after TIMEOUT ms.classSimpleTCPBare-bones thread-per-connection TCP-based transport.classSIZEProtocol which lists how many messages have been received by size: https://issues.redhat.com/browse/JGRP-2893
Don't use this layer in a production stack since the costs are high; only use for debugging/diagnosis.classSIZE2Records number of messages sent/received based on sizeclassSNIFFProtocol trying to print message payloads as stringsclassSOSPeriodically fetches some attributes and writes them to a file (https://issues.redhat.com/browse/JGRP-2402)classSSL_KEY_EXCHANGEKey exchange based on SSL sockets.classSTATSProvides various statsclassSTOMPProtocol which provides STOMP (https://stomp.github.io/) support.classSWIFT_PINGDiscovery protocol based on Openstack Swift (object storage).classSYM_ENCRYPTEncrypts and decrypts communication in JGroups by using a secret key shared by all cluster members.classTCPTCP based protocol.classTCP_NIO2Protocol using TCP/IP to send and receive messages.classTCPGOSSIPThe TCPGOSSIP protocol layer retrieves the initial membership (used by GMS when started by sending event FIND_INITIAL_MBRS down the stack).classTCPPINGThe TCPPING protocol defines a static cluster membership.classTHREAD_COUNTMaintains averages of up- and down-threadsclassTIMEProtocol measuring delivery times.classTPGeneric transport - specific implementations should extend this abstract class.classTRACEclassTUNNELReplacement for UDP.classUDPIP multicast transport based on UDP.classUFCSimple flow control protocol based on a credit system.classUFC_NBNon-blocking alternative toUFC.
JIRA: https://issues.redhat.com/browse/JGRP-2172classUNBATCHInterceptsup(MessageBatch)and passes up each message of a message batch as a single message.classUNBATCH_OOBUnbatches OOB batches when enabled and virtual threads are available.
https://issues.redhat.com/browse/JGRP-2888classUNICAST3Reliable unicast protocol using a combination of positive and negative acks.classUNICAST4New unicast protocol based on fixed-size xmit windows and message ACKs
Details: https://issues.redhat.com/browse/JGRP-2843classVERIFY_SUSPECTCatches SUSPECT events traveling up the stack.classVERIFY_SUSPECT2Double-checks that a suspected member is really dead.
Details: https://issues.redhat.com/browse/JGRP-2558
Design: https://github.com/belaban/JGroups/blob/master/doc/design/VERIFY_SUSPECT2.txtFields in org.jgroups.protocols with type parameters of type Protocol Modifier and Type Field Description protected java.util.concurrent.ConcurrentMap<java.lang.String,Protocol>FORK. fork_stacksMethods in org.jgroups.protocols with type parameters of type Protocol Modifier and Type Method Description protected <T extends Protocol>
TRSVP. findDownProtocol(java.lang.Class<? extends Protocol> cl)protected <T extends Protocol>
TKeyExchange. findProtocolAbove(java.lang.Class<? extends Protocol> clazz)<T extends Protocol>
TFORK. setAddress(Address addr)<T extends Protocol>
TTP. setAddress(Address addr)<T extends Protocol>
TReliableMulticast. setLevel(java.lang.String level)<T extends Protocol>
TReliableUnicast. setLevel(java.lang.String level)<T extends Protocol>
TTP. setLevel(java.lang.String level)<T extends Protocol>
TUNICAST3. setLevel(java.lang.String level)Methods in org.jgroups.protocols that return Protocol Modifier and Type Method Description ProtocolFORK. get(java.lang.String fork_stack_id)ProtocolFORK. putIfAbsent(java.lang.String fork_stack_id, Protocol p)Methods in org.jgroups.protocols with parameters of type Protocol Modifier and Type Method Description static ForkProtocolStackFORK. getForkStack(Protocol prot)protected voidFORK. getStateFrom(JChannel channel, Protocol prot, java.lang.String stack, java.lang.String ch, java.io.DataOutputStream out)ProtocolFORK. putIfAbsent(java.lang.String fork_stack_id, Protocol p)Method parameters in org.jgroups.protocols with type arguments of type Protocol Modifier and Type Method Description ProtocolStackFORK. createForkStack(java.lang.String fork_stack_id, java.util.List<Protocol> protocols, boolean initialize)Returns the fork stack for fork_stack_id (if exitstent), or creates a new fork-stack from protocols and adds it into the hashmap of fork-stack (key is fork_stack_id).protected <T extends Protocol>
TRSVP. findDownProtocol(java.lang.Class<? extends Protocol> cl)protected <T extends Protocol>
TKeyExchange. findProtocolAbove(java.lang.Class<? extends Protocol> clazz) -
Uses of Protocol in org.jgroups.protocols.dns
Subclasses of Protocol in org.jgroups.protocols.dns Modifier and Type Class Description classDNS_PING -
Uses of Protocol in org.jgroups.protocols.pbcast
Subclasses of Protocol in org.jgroups.protocols.pbcast Modifier and Type Class Description classGMSGroup membership protocol.classNAKACK2Negative AcKnowledgement layer (NAKs).classSTABLEComputes the broadcast messages that are stable; i.e., have been delivered by all members.classSTATESTATE streams the state (written to an OutputStream) to the state requester in chunks (defined by chunk_size).classSTATE_SOCKSTATE_SOCKhas the state provider create a server socket to which the state requester connects and from which the latter reads the state.classSTATE_TRANSFERSTATE_TRANSFER protocol based on byte array transfer.classStreamingStateTransferBase class for state transfer protocols which use streaming (or chunking) to transfer state between two members.Methods in org.jgroups.protocols.pbcast with type parameters of type Protocol Modifier and Type Method Description <T extends Protocol>
TNAKACK2. setLevel(java.lang.String level) -
Uses of Protocol in org.jgroups.protocols.relay
Subclasses of Protocol in org.jgroups.protocols.relay Modifier and Type Class Description classRELAYclassRELAY2Design: ./doc/design/RELAY2.txt and at https://github.com/belaban/JGroups/blob/master/doc/design/RELAY2.txt.classRELAY3Provides relaying of messages between autonomous sites.
Design: ./doc/design/RELAY2.txt and at https://github.com/belaban/JGroups/blob/master/doc/design/RELAY2.txt.
JIRA: https://issues.redhat.com/browse/JGRP-1433 -
Uses of Protocol in org.jgroups.protocols.relay.config
Fields in org.jgroups.protocols.relay.config declared as Protocol Modifier and Type Field Description protected Protocol[]RelayConfig.ProgrammaticBridgeConfig. protocolsMethods in org.jgroups.protocols.relay.config with parameters of type Protocol Modifier and Type Method Description protected static java.lang.StringRelayConfig.ProgrammaticBridgeConfig. printProtocols(Protocol[] protocols)Constructors in org.jgroups.protocols.relay.config with parameters of type Protocol Constructor Description ProgrammaticBridgeConfig(java.lang.String cluster_name, Protocol[] prots) -
Uses of Protocol in org.jgroups.stack
Subclasses of Protocol in org.jgroups.stack Modifier and Type Class Description classProtocolStackA ProtocolStack manages a number of protocols layered above each other.Fields in org.jgroups.stack declared as Protocol Modifier and Type Field Description protected ProtocolProtocolStack. bottom_protprotected ProtocolProtocol. down_protprotected ProtocolProtocolStack. top_protprotected ProtocolProtocol. up_protMethods in org.jgroups.stack with type parameters of type Protocol Modifier and Type Method Description <T extends Protocol>
TProtocol. addPolicy(Policy p)<T extends Protocol>
TProtocol. addr(Address addr)<T extends Protocol>
TProtocolStack. findProtocol(java.lang.Class<? extends Protocol> clazz)<T extends Protocol>
TProtocolStack. findProtocol(java.lang.Class<? extends Protocol>... classes)Finds the first protocol of a list and returns it.<T extends Protocol>
TProtocolStack. findProtocol(java.lang.String name)Returns a given protocol or null if not foundstatic <T extends Protocol>
TProtocolStack. findProtocol(Protocol start, boolean down, java.lang.Class<? extends Protocol> clazz)<T extends Protocol>
java.util.List<T>ProtocolStack. findProtocols(java.lang.String regexp)<T extends Protocol>
TProtocolStack. getBottomProtocol()<T extends Protocol>
TProtocol. getDownProtocol()<T extends Protocol>
TProtocol. getUpProtocol()<T extends Protocol>
TProtocol. level(java.lang.String level)<T extends Protocol>
TProtocol. removePolicy(Policy p)<T extends Protocol>
TProtocolStack. removeProtocol(java.lang.Class<? extends Protocol> prot)<T extends Protocol>
TProtocolStack. removeProtocol(java.lang.Class<? extends Protocol>... protocols)<T extends Protocol>
TProtocolStack. removeProtocol(java.lang.String prot_name)Removes a protocol from the stack.<T extends Protocol>
TProtocolStack. removeProtocol(T prot)<T extends Protocol>
TProtocol. setAddress(Address addr)<T extends Protocol>
TProtocol. setDownProtocol(Protocol prot)<T extends Protocol>
TProtocol. setErgonomics(boolean ergonomics)<T extends Protocol>
TProtocol. setId(short id)<T extends Protocol>
TProtocol. setLevel(java.lang.String level)Sets the level of a logger.<T extends Protocol>
TProtocol. setPolicies(java.util.List<Policy> l)<T extends Protocol>
TProtocol. setProtocolStack(ProtocolStack s)<T extends Protocol>
TProtocol. setUpProtocol(Protocol prot)<T extends Protocol>
TProtocol. setValue(java.lang.String name, java.lang.Object value)Methods in org.jgroups.stack that return Protocol Modifier and Type Method Description static ProtocolConfigurator. connectProtocols(java.util.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(java.lang.String prot_spec, ProtocolStack stack)static ProtocolConfigurator. createProtocol(java.lang.String prot_spec, ProtocolStack stack, boolean init_attrs)Creates a new protocol given the protocol specification.protected ProtocolProtocolStack. createProtocol(java.lang.String classname)ProtocolProtocolStack. getTopProtocol()ProtocolConfigurator. setupProtocolStack(java.util.List<ProtocolConfiguration> config)static ProtocolConfigurator. setupProtocolStack(java.util.List<ProtocolConfiguration> protocol_configs, ProtocolStack st)Sets up the protocol stack.Methods in org.jgroups.stack that return types with arguments of type Protocol Modifier and Type Method Description static java.util.List<Protocol>Configurator. createProtocols(java.util.List<ProtocolConfiguration> protocol_configs, ProtocolStack stack)Takes a list of configurations, creates a protocol for each and returns all protocols in a list.static java.util.List<Protocol>Configurator. createProtocolsAndInitializeAttrs(java.util.List<ProtocolConfiguration> cfgs, ProtocolStack st)java.util.List<Protocol>ProtocolStack. getProtocols()Returns all protocols in a list, from top to bottom.Methods in org.jgroups.stack with parameters of type Protocol Modifier and Type Method Description ProtocolStackProtocolStack. addProtocol(Protocol prot)Adds a protocol at the tail of the protocol listProtocolStackProtocolStack. addProtocols(Protocol... prots)Adds a list of protocolsvoidProtocolHook. afterCreation(Protocol prot)Called after all protocols have been created, connected and its attributes set, but beforeinit()is called.ProtocolStackProtocolStack. bottomProtocol(Protocol bottom)protected static voidProtocolStack. callAfterCreationHook(Protocol prot, java.lang.String classname)voidPolicy. check(Protocol prot)Checks that a condition is met in a given protocolprotected java.lang.reflect.MethodNonReflectiveProbeHandler. findMethod(Protocol prot, java.lang.String method_name, java.lang.String[] args)static <T extends Protocol>
TProtocolStack. findProtocol(Protocol start, boolean down, java.lang.Class<? extends Protocol> clazz)static voidProtocolStack. initComponents(Protocol p, ProtocolConfiguration cfg)NonReflectiveProbeHandlerNonReflectiveProbeHandler. initialize(Protocol[] protocols)static voidConfigurator. initializeAttrs(Protocol prot, ProtocolConfiguration config, StackType ip_version)Sets the attributes in a given protocol from propertiesvoidProtocolStack. insertProtocol(Protocol prot, ProtocolStack.Position position, java.lang.Class<? extends Protocol> neighbor_prot)voidProtocolStack. insertProtocol(Protocol prot, ProtocolStack.Position position, java.lang.Class<? extends Protocol>... neighbor_prots)voidProtocolStack. insertProtocol(Protocol prot, ProtocolStack.Position position, java.lang.String neighbor_prot)Inserts an already created (and initialized) protocol into the protocol list.voidProtocolStack. insertProtocolAtTop(Protocol prot)voidProtocolStack. insertProtocolInStack(Protocol prot, Protocol neighbor, ProtocolStack.Position position)protected static voidConfigurator. removeProvidedDownServices(Protocol protocol, java.util.List<java.lang.Integer> events)Removes all events provided by the protocol above protocol from eventsprotected static voidConfigurator. removeProvidedUpServices(Protocol protocol, java.util.List<java.lang.Integer> events)Removes all events provided by the protocol below protocol from eventsvoidProtocolStack. replaceProtocol(Protocol existing_prot, Protocol new_prot)Replaces one protocol instance with another.<T extends Protocol>
TProtocol. setDownProtocol(Protocol prot)<T extends Protocol>
TProtocol. setUpProtocol(Protocol prot)ProtocolStackProtocolStack. topProtocol(Protocol top)Method parameters in org.jgroups.stack with type arguments of type Protocol Modifier and Type Method Description ProtocolStackProtocolStack. addProtocols(java.util.List<Protocol> prots)Adds a list of protocolsstatic ProtocolConfigurator. connectProtocols(java.util.List<Protocol> protocol_list)Creates a protocol stack by iterating through the protocol list and connecting adjacent layers.static voidConfigurator. ensureValidBindAddresses(java.util.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<T extends Protocol>
TProtocolStack. findProtocol(java.lang.Class<? extends Protocol> clazz)static <T extends Protocol>
TProtocolStack. findProtocol(Protocol start, boolean down, java.lang.Class<? extends Protocol> clazz)static java.util.List<java.net.InetAddress>Configurator. getInetAddresses(java.util.List<Protocol> protocols)static java.util.Map<java.lang.String,java.net.InetAddress>Configurator. getInetAddresses2(java.util.List<Protocol> protocols)Returns a map of protocol.attr/InetAddress tuplesNonReflectiveProbeHandlerNonReflectiveProbeHandler. initialize(java.util.Collection<Protocol> prots)voidProtocolStack. insertProtocol(Protocol prot, ProtocolStack.Position position, java.lang.Class<? extends Protocol> neighbor_prot)<T extends Protocol>
TProtocolStack. removeProtocol(java.lang.Class<? extends Protocol> prot)static voidConfigurator. sanityCheck(java.util.List<Protocol> protocols)Throws an exception if sanity check fails.static voidConfigurator. setDefaultAddressValues(java.util.List<Protocol> protocols, StackType ip_version)Processes fields and methods which are inet address related, and assigns them default values defined by (Property.defaultValueIPv4()andProperty.defaultValueIPv6()). -
Uses of Protocol in org.jgroups.util
Subclasses of Protocol in org.jgroups.util Modifier and Type Class Description classMockTransportA dummy implementation ofTPMethods in org.jgroups.util that return Protocol Modifier and Type Method Description static Protocol[]Util. getTestStack(Protocol... additional_protocols)Returns a default stack for testing with transport = SHARED_LOOPBACKstatic Protocol[]Util. getTestStackNew(Protocol... additional_protocols)Methods in org.jgroups.util that return types with arguments of type Protocol Modifier and Type Method Description static java.lang.Class<? extends Protocol>[]Util. getUnicastProtocols()static java.lang.Class<? extends Protocol>Util. loadProtocolClass(java.lang.String protocol_name, java.lang.Class<?> cl)Methods in org.jgroups.util with parameters of type Protocol Modifier and Type Method Description voidProtPerfHelper. downTime(Message msg, Protocol prot)static java.util.Map<java.lang.String,Metrics.Entry<java.lang.Object>>Metrics. extract(Protocol p)static java.util.Map<java.lang.String,Metrics.Entry<java.lang.Object>>Metrics. extract(Protocol p, java.util.function.Predicate<java.lang.reflect.AccessibleObject> filter)protected static java.lang.StringProtPerfHelper. getClusterName(Protocol p)static Protocol[]Util. getTestStack(Protocol... additional_protocols)Returns a default stack for testing with transport = SHARED_LOOPBACKstatic Protocol[]Util. getTestStackNew(Protocol... additional_protocols)voidProtPerfHelper. upTime(Message msg, Protocol prot)voidProtPerfHelper. upTime(MessageBatch batch, Protocol prot)
-