Uses of Class
org.jgroups.Message

Packages that use Message

Package	Description
org.jgroups	Provides top-level public JGroups classes such as Channel, Message, etc.
org.jgroups.auth
org.jgroups.auth.sasl
org.jgroups.blocks	Provides building blocks that are layered on top of channels.
org.jgroups.demos	Provides demonstrations of JGroups functionality.
org.jgroups.fork
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.rules
org.jgroups.protocols.tom
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 Message in org.jgroups

Methods in org.jgroups that return Message

Modifier and Type	Method	Description
Message	Message.buffer(byte[] b)
Message	Message.buffer(Buffer b)
Message	Message.clearFlag(Message.Flag... flags)	Clears a number of flags in a message
Message	Message.clearTransientFlag(Message.TransientFlag... flags)
Message	Message.copy()
Message	Message.copy(boolean copy_buffer)	Create a copy of the message.
Message	Message.copy(boolean copy_buffer, boolean copy_headers)	Create a copy of the message.
Message	Message.copy(boolean copy_buffer, short starting_id)	Doesn't copy any headers except for those with ID >= copy_headers_above
Message	Message.copy(boolean copy_buffer, short starting_id, short... copy_only_ids)	Copies a message.
Message	Message.dest(Address new_dest)
Message	Message.makeReply()
Message	Message.putHeader(short id, Header hdr)	Puts a header given an ID into the hashmap.
Message	Message.setBuffer(byte[] b)	Sets the buffer.
Message	Message.setBuffer(byte[] b, int offset, int length)	Sets the internal buffer to point to a subset of a given buffer.
Message	Message.setBuffer(Buffer buf)	Sets the buffer
Message	Message.setDest(Address new_dest)
Message	Message.setFlag(short flag)	Sets the flags from a short.
Message	Message.setFlag(Message.Flag... flags)	Sets a number of flags in a message
Message	Message.setObject(java.lang.Object obj)	Takes an object and uses Java serialization to generate the byte[] buffer which is set in the message.
Message	Message.setSrc(Address new_src)
Message	Message.setTransientFlag(short flag)
Message	Message.setTransientFlag(Message.TransientFlag... flags)	Same as setFlag(Flag...) except that transient flags are not marshalled
Message	Message.src(Address new_src)

Methods in org.jgroups that return types with arguments of type Message

Modifier and Type	Method	Description
java.util.function.Supplier<? extends Message>	Message.create()

Methods in org.jgroups with parameters of type Message

Modifier and Type	Method	Description
java.lang.Object	JChannel.down(Message msg)
void	MessageListener.receive(Message msg)	Called when a message is received.
void	ReceiverAdapter.receive(Message msg)
void	Channel.send(Message msg)	Deprecated. Sends a message.
JChannel	JChannel.send(Message msg)	Sends a message.
java.lang.Object	JChannel.up(Message msg)
java.lang.Object	UpHandler.up(Message msg)

Uses of Message in org.jgroups.auth

Methods in org.jgroups.auth with parameters of type Message

Modifier and Type	Method	Description
abstract boolean	AuthToken.authenticate(AuthToken token, Message msg)	This method should be implemented to perform the actual authentication of joining members.
boolean	FixedMembershipToken.authenticate(AuthToken token, Message msg)	Check if I'm in memberList, too
boolean	Krb5Token.authenticate(AuthToken token, Message msg)
boolean	MD5Token.authenticate(AuthToken token, Message msg)	Deprecated.
boolean	RegexMembership.authenticate(AuthToken token, Message msg)
boolean	SimpleToken.authenticate(AuthToken token, Message msg)	Deprecated.
boolean	X509Token.authenticate(AuthToken token, Message msg)

Uses of Message in org.jgroups.auth.sasl

Methods in org.jgroups.auth.sasl that return Message

Modifier and Type	Method	Description
Message	SaslClientContext.addHeader(Message msg, byte[] payload)
Message	SaslClientContext.nextMessage(Address address, SaslHeader header)
Message	SaslContext.nextMessage(Address address, SaslHeader saslHeader)
Message	SaslServerContext.nextMessage(Address address, SaslHeader header)

Methods in org.jgroups.auth.sasl with parameters of type Message

Modifier and Type	Method	Description
Message	SaslClientContext.addHeader(Message msg, byte[] payload)

Uses of Message in org.jgroups.blocks

Fields in org.jgroups.blocks declared as Message

Modifier and Type	Field	Description
protected Message	RequestCorrelator.ResponseImpl.req

Methods in org.jgroups.blocks with parameters of type Message

Modifier and Type	Method	Description
protected void	RequestCorrelator.dispatch(Message msg, RequestCorrelator.Header hdr)
java.lang.Object	MessageDispatcher.handle(Message msg)
void	MessageDispatcher.handle(Message request, Response response)
java.lang.Object	RequestHandler.handle(Message msg)	Processes a request synchronously, ie.
default void	RequestHandler.handle(Message request, Response response)	Processes a request asynchronously.
java.lang.Object	RpcDispatcher.handle(Message req)	Message contains MethodCall.
protected void	RequestCorrelator.handleRequest(Message req, RequestCorrelator.Header hdr)	Handle a request msg for this correlator
void	ReplicatedTree.receive(Message msg)	Callback.
boolean	RequestCorrelator.receiveMessage(Message msg)	Handles a message coming from a layer below
void	RequestCorrelator.ResponseImpl.send(Message reply, boolean is_exception)
void	Response.send(Message reply, boolean is_exception)	Similar to Response.send(Object,boolean), but passes a message instead of an object.
protected void	RequestCorrelator.sendReply(Message req, long req_id, java.lang.Object reply, boolean is_exception)
protected void	RequestCorrelator.sendResponse(Message rsp, long req_id, boolean is_exception)

Constructors in org.jgroups.blocks with parameters of type Message

Constructor	Description
ResponseImpl(Message req, long req_id)

Uses of Message in org.jgroups.demos

Methods in org.jgroups.demos with parameters of type Message

Modifier and Type	Method	Description
void	Chat.receive(Message msg)
void	Draw.receive(Message msg)
void	RelayDemo.receive(Message msg)

Uses of Message in org.jgroups.fork

Methods in org.jgroups.fork with parameters of type Message

Modifier and Type	Method	Description
java.lang.Object	ForkChannel.down(Message msg)
java.lang.Object	ForkProtocol.down(Message msg)
java.lang.Object	ForkProtocolStack.down(Message msg)
java.lang.Object	UnknownForkHandler.handleUnknownForkChannel(Message message, java.lang.String forkChannelId)	Handle a message that refers to an unknown fork channel
java.lang.Object	UnknownForkHandler.handleUnknownForkStack(Message message, java.lang.String forkStackId)	Handle a message that refers to an unknown fork stack
ForkChannel	ForkChannel.send(Message msg)
protected void	ForkChannel.setHeader(Message msg)
java.lang.Object	ForkProtocolStack.up(Message msg)

Uses of Message in org.jgroups.protocols

Fields in org.jgroups.protocols declared as Message

Modifier and Type	Field	Description
protected Message[]	RingBufferBundlerLockless.buf
protected Message[]	RingBufferBundlerLockless2.buf
protected static Message	UNICAST3.DUMMY_OOB_MSG
protected Message	FRAG3.FragEntry.msg
protected Message[]	SimplifiedTransferQueueBundler.msg_queue
static Message	RingBufferBundlerLockless2.NULL_MSG
protected Message[]	RemoveQueueBundler.remove_queue

Fields in org.jgroups.protocols with type parameters of type Message

Modifier and Type	Field	Description
protected static java.util.function.BiConsumer<MessageBatch,Message>	SEQUENCER2.BATCH_ACCUMULATOR
protected static java.util.function.BiConsumer<MessageBatch,Message>	UNICAST3.BATCH_ACCUMULATOR
protected static java.util.function.Predicate<Message>	UNICAST3.dont_loopback_filter
protected java.util.List<java.util.function.Predicate<Message>>	DROP.down_filters
protected java.util.List<Message>	SHUFFLE.down_msgs
protected java.util.function.Predicate<Message>	UNICAST3.drop_oob_and_dont_loopback_msgs_filter
protected java.util.function.Predicate<Message>	REVERSE.filter
protected java.util.NavigableMap<java.lang.Long,Message>	SEQUENCER.forward_table	Maintains messages forwarded to the coord which which no ack has been received yet.
protected java.util.concurrent.BlockingQueue<Message>	SEQUENCER2.fwd_queue
protected java.util.function.Predicate<Message>	FailureDetection.HAS_HEADER
protected java.util.Map<Address,Message>	BARRIER.mcast_queue
protected java.util.Map<Address,java.util.List<Message>>	BaseBundler.msgs	Keys are destinations, values are lists of Messages
protected Table<Message>	UNICAST3.Entry.msgs
protected java.util.Map<Address,java.util.List<Message>>	MAKE_BATCH.oob_map_mcast
protected java.util.Map<Address,java.util.List<Message>>	MAKE_BATCH.oob_map_ucast
protected java.util.Deque<Message>	REVERSE.queue
protected java.util.concurrent.BlockingQueue<Message>	TransferQueueBundler.queue
protected RingBuffer<Message>	RemoveQueueBundler.rb
protected RingBuffer<Message>	RingBufferBundler.rb
protected Table<Message>	SEQUENCER2.received_msgs
protected java.util.Map<Address,java.util.List<Message>>	MAKE_BATCH.reg_map_mcast
protected java.util.Map<Address,java.util.List<Message>>	MAKE_BATCH.reg_map_ucast
protected java.util.List<Message>	TransferQueueBundler.remove_queue
protected java.util.function.Consumer<Message>	MFC_NB.send_function
protected java.util.function.Consumer<Message>	UFC_NB.send_function
protected java.util.concurrent.BlockingQueue<Message>	ABP.Entry.send_queue
protected java.util.List<Message>	AlternatingBundler.target_list
protected java.util.Map<Address,Message>	BARRIER.ucast_queue
protected java.util.List<java.util.function.Predicate<Message>>	DROP.up_filters
protected java.util.List<Message>	SHUFFLE.up_msgs

Methods in org.jgroups.protocols that return Message

Modifier and Type	Method	Description
protected Message	Encrypt._decrypt(javax.crypto.Cipher cipher, java.security.Key key, Message msg, byte[] iv)
protected Message	ASYM_ENCRYPT.addKeysToMessage(Message msg, boolean copy, boolean add_secret_keys, Address serialize_only)	Adds the public and/or encrypted shared keys to the payload of msg.
protected Message	FRAG2.FragEntry.assembleMessage()	Assembles all the fragments into one buffer.
protected Message	FRAG3.FragEntry.assembleMessage()	Assembles all the fragments into one buffer.
protected Message	Encrypt.decryptMessage(javax.crypto.Cipher cipher, Message msg)	Does the actual work for decrypting - if version does not match current cipher then tries the previous cipher
protected static Message	SERIALIZE.deserialize(Message msg)
protected Message	Encrypt.encrypt(Message msg)
Message	FRAG3.FragEntry.set(Message frag_msg, Frag3Header hdr)	Adds a fragment to the full message
protected Message	COMPRESS.uncompress(Message msg, int original_size)	Returns a new message as a result of uncompressing msg, or null if msg couldn't be uncompressed
protected Message	FRAG2.unfragment(Message msg, FragHeader hdr)	1.
protected Message	FRAG3.unfragment(Message msg, Frag3Header hdr)	1.

Methods in org.jgroups.protocols that return types with arguments of type Message

Modifier and Type	Method	Description
RingBuffer<Message>	RingBufferBundler.buf()
java.util.function.Predicate<Message>	REVERSE.filter()

Methods in org.jgroups.protocols with parameters of type Message

Modifier and Type	Method	Description
protected void	AlternatingBundler._addMessage(Message msg, long size)
protected void	TransferQueueBundler._addMessage(Message msg, long size)
protected Message	Encrypt._decrypt(javax.crypto.Cipher cipher, java.security.Key key, Message msg, byte[] iv)
protected java.lang.Object	SimpleTCP._down(Message msg)
protected void	TP._send(Message msg, Address dest)
void	Encrypt.Decrypter.accept(Message msg, MessageBatch batch)
protected SHUFFLE	SHUFFLE.add(java.util.List<Message> queue, Message msg, java.util.concurrent.locks.Lock lock, java.util.function.Consumer<Message> send_function)
protected void	TransferQueueBundler.addAndSendIfSizeExceeded(Message msg)
protected Message	ASYM_ENCRYPT.addKeysToMessage(Message msg, boolean copy, boolean add_secret_keys, Address serialize_only)	Adds the public and/or encrypted shared keys to the payload of msg.
protected void	BaseBundler.addMessage(Message msg, long size)
protected void	SimplifiedTransferQueueBundler.addMessage(Message msg, long size)
protected void	UNICAST3.addMessage(UNICAST3.ReceiverEntry entry, Address sender, long seqno, Message msg)
protected ASYM_ENCRYPT.Processing	ASYM_ENCRYPT.addMetadata(Message msg, boolean add_secret_keys, Address include_secret_key_only_for, boolean attach_fetch_key_header)
protected void	SEQUENCER.broadcast(Message msg, boolean copy, Address original_sender, long seqno, boolean resend)
protected void	SEQUENCER2.broadcast(Message msg, long seqno)
protected Message	Encrypt.decryptMessage(javax.crypto.Cipher cipher, Message msg)	Does the actual work for decrypting - if version does not match current cipher then tries the previous cipher
protected void	SEQUENCER.deliver(Message msg, SEQUENCER.SequencerHeader hdr)
protected void	SEQUENCER2.deliver(Message msg, SEQUENCER2.SequencerHeader hdr)
protected void	UNICAST3.deliverMessage(Message msg, Address sender, long seqno)
protected static Message	SERIALIZE.deserialize(Message msg)
java.lang.Object	ABP.down(Message msg)	Deprecated.
java.lang.Object	ASYM_ENCRYPT.down(Message msg)
java.lang.Object	AUTH.down(Message msg)
java.lang.Object	CLEAR_FLAGS.down(Message msg)
java.lang.Object	COMPRESS.down(Message msg)	We compress the payload if it is larger than min_size.
java.lang.Object	DAISYCHAIN.down(Message msg)
java.lang.Object	DELAY.down(Message msg)
java.lang.Object	DETECT_LOOPBACKS.down(Message msg)
java.lang.Object	DISCARD_PAYLOAD.down(Message msg)
java.lang.Object	DISCARD.down(Message msg)
java.lang.Object	DROP.down(Message msg)
java.lang.Object	DUPL.down(Message msg)
java.lang.Object	Encrypt.down(Message msg)
java.lang.Object	EXAMPLE.down(Message msg)
java.lang.Object	FailureDetection.down(Message msg)
java.lang.Object	FlowControl.down(Message msg)
java.lang.Object	FRAG.down(Message msg)
java.lang.Object	FRAG2.down(Message msg)
java.lang.Object	FRAG3.down(Message msg)
java.lang.Object	HDRS.down(Message msg)
java.lang.Object	PERF.down(Message msg)
java.lang.Object	RATE_LIMITER.down(Message msg)
java.lang.Object	RATE.down(Message msg)
java.lang.Object	RED.down(Message msg)
java.lang.Object	RELAY.down(Message msg)	Deprecated.
java.lang.Object	RSVP.down(Message msg)
java.lang.Object	SASL.down(Message msg)	Deprecated.
java.lang.Object	SEQUENCER.down(Message msg)
java.lang.Object	SEQUENCER2.down(Message msg)
java.lang.Object	SERIALIZE.down(Message msg)
java.lang.Object	SHUFFLE.down(Message msg)
java.lang.Object	SimpleTCP.down(Message msg)
java.lang.Object	SIZE.down(Message msg)
java.lang.Object	SNIFF.down(Message msg)
java.lang.Object	STATS.down(Message msg)
java.lang.Object	TP.down(Message msg)	A message needs to be sent to a single member or all members
java.lang.Object	TRACE.down(Message msg)
java.lang.Object	UNICAST3.down(Message msg)
protected boolean	ASYM_ENCRYPT.dropMulticastMessageFromNonMember(Message msg)
protected void	DROP.dropped(Message msg, boolean down)
protected static void	SNIFF.dump(java.lang.String type, Message msg)
protected Message	Encrypt.encrypt(Message msg)
protected void	Encrypt.encryptAndSend(Message msg)
protected void	SEQUENCER.forward(Message msg, long seqno, boolean flush)
protected void	RELAY.forwardToCoord(Message msg)	Deprecated. Wraps the message annd sends it to the current coordinator
protected void	SEQUENCER.forwardToCoord(long seqno, Message msg)
protected void	FRAG2.fragment(Message msg)	Send all fragments as separate messages (with same ID !).
protected void	FRAG3.fragment(Message msg)	Send all fragments as separate messages (with same ID !).
protected static GMS.GmsHeader	AUTH.getGMSHeader(Message msg)
protected byte[]	ASYM_ENCRYPT.getIv(Message msg)
protected static JoinRsp	AUTH.getJoinResponse(Message msg)
protected boolean	AUTH.handleAuthHeader(GMS.GmsHeader gms_hdr, AuthHeader auth_hdr, Message msg)	Handles a GMS header
protected void	NAMING.handleCacheResponse(Message msg)
protected void	UNICAST3.handleDataReceived(Address sender, long seqno, short conn_id, boolean first, Message msg)	Check whether the hashtable contains an entry e for sender (create if not).
protected void	UNICAST3.handleDataReceivedFromSelf(Address sender, long seqno, Message msg)	Called when the sender of a message is the local member.
protected abstract java.lang.Object	FlowControl.handleDownMessage(Message msg)
protected java.lang.Object	MFC_NB.handleDownMessage(Message msg)
protected java.lang.Object	MFC.handleDownMessage(Message msg)
protected java.lang.Object	UFC_NB.handleDownMessage(Message msg)
protected java.lang.Object	UFC.handleDownMessage(Message msg)
protected java.lang.Object	Encrypt.handleEncryptedMessage(Message msg)
protected java.lang.Object	NAMING.handleMessage(Message msg, NAMING.Header hdr)
protected void	FlowControl.handleUpEvent(Message msg, FcHeader hdr)
protected java.lang.Object	RELAY.handleUpEvent(Message msg, RELAY.RelayHeader hdr)	Deprecated.
protected void	UNICAST3.handleUpEvent(Address sender, Message msg, UnicastHeader3 hdr)
protected void	TP.loopback(Message msg, boolean multicast)
protected int	RingBufferBundler.marshalMessagesToSameDestination(Address dest, Message[] buf, int start_index, int end_index, int max_bundle_size)
protected int	RingBufferBundlerLockless.marshalMessagesToSameDestination(Address dest, Message[] buf, int start_index, int available_msgs, int max_bundle_size)
protected int	RingBufferBundlerLockless2.marshalMessagesToSameDestination(Address dest, Message[] buf, int start_index, int end_index, int max_bundle_size)
protected boolean	AUTH.needsAuthentication(Message msg, GMS.GmsHeader hdr)
protected static int	SIZE.numHeaders(Message msg)
void	TP.passMessageUp(Message msg, byte[] cluster_name, boolean perform_cluster_name_matching, boolean multicast, boolean discard_own_mcast)
protected static java.lang.String	SNIFF.printPayload(Message msg, java.lang.StringBuilder sb)
protected boolean	ASYM_ENCRYPT.processEncryptMessage(Message msg, EncryptHeader hdr, boolean retval)
protected void	MAKE_BATCH.queue(Message msg)
void	RELAY.Receiver.receive(Message msg)
protected void	ASYM_ENCRYPT.removeKeysFromMessageAndInstall(Message msg, byte[] version)	Removes the public and/or private keys from the payload of msg and installs them.
protected void	UNICAST3.retransmit(Message msg)	Called by the sender to resend messages for which no ACK has been received yet
protected void	ABP.Entry.send(Message msg)
void	AsyncNoBundler.send(Message msg)
void	BaseBundler.send(Message msg)
void	Bundler.send(Message msg)
void	NoBundler.send(Message msg)
void	RemoveQueueBundler.send(Message msg)
void	RingBufferBundler.send(Message msg)
void	RingBufferBundlerLockless.send(Message msg)
void	RingBufferBundlerLockless2.send(Message msg)
void	SenderSendsBundler.send(Message msg)
protected void	TP.send(Message msg)	Serializes and sends a message.
void	TransferQueueBundler.send(Message msg)
void	RingBufferBundler.sendBundledMessages(Message[] buf, int read_index, int available_msgs)	Read and send messages in range [read-index ..
protected int	RingBufferBundlerLockless.sendBundledMessages(Message[] buf, int read_index, int available_msgs)	Read and send messages in range [read-index ..
protected int	RingBufferBundlerLockless2.sendBundledMessages(Message[] buf, int read_index, int write_index)	Read and send messages in range [read-index+1 ..
protected void	TCPPING.sendDiscoveryRequest(Message req)
protected void	BPING.sendMcastDiscoveryRequest(Message msg)
protected void	MPING.sendMcastDiscoveryRequest(Message msg)
protected void	PING.sendMcastDiscoveryRequest(Message msg)
protected void	BaseBundler.sendSingleMessage(Message msg)
protected void	NoBundler.sendSingleMessage(Message msg, ByteArrayDataOutputStream output)
protected boolean	SASL.serverChallenge(GMS.GmsHeader gmsHeader, SaslHeader saslHeader, Message msg)	Deprecated.
void	FRAG2.FragEntry.set(int frag_id, Message frag)	adds on fragmentation buffer to the message
Message	FRAG3.FragEntry.set(Message frag_msg, Frag3Header hdr)	Adds a fragment to the full message
protected void	TP.setSourceAddress(Message msg)	If the sender is null, set our own address.
protected boolean	DISCARD.shouldDropUpMessage(Message msg, Address sender)	Checks if a message should be passed up, or not
protected long	RATE.size(Message msg)
protected ASYM_ENCRYPT.Processing	ASYM_ENCRYPT.skipDownMessage(Message msg)	Processes a message with a GMS header (e.g.
protected boolean	ASYM_ENCRYPT.skipUpMessage(Message msg)	Checks if the message contains a public key (and adds it to pub_map if present) or an encrypted group key (and installs it if present)
protected Message	COMPRESS.uncompress(Message msg, int original_size)	Returns a new message as a result of uncompressing msg, or null if msg couldn't be uncompressed
protected Message	FRAG2.unfragment(Message msg, FragHeader hdr)	1.
protected Message	FRAG3.unfragment(Message msg, Frag3Header hdr)	1.
protected void	SEQUENCER.unwrapAndDeliver(Message msg, boolean flush_ack)	Unmarshal the original message (in the payload) and then pass it up (unless already delivered)
java.lang.Object	ABP.up(Message msg)	Deprecated.
java.lang.Object	ASYM_ENCRYPT.up(Message msg)
java.lang.Object	AUTH.up(Message msg)	An event was received from the layer below.
java.lang.Object	BARRIER.up(Message msg)
java.lang.Object	COMPRESS.up(Message msg)	If there is no header, we pass the message up.
java.lang.Object	COUNTER.up(Message msg)
java.lang.Object	DAISYCHAIN.up(Message msg)
java.lang.Object	DELAY.up(Message msg)
java.lang.Object	DELIVERY_TIME.up(Message msg)
java.lang.Object	DH_KEY_EXCHANGE.up(Message msg)
java.lang.Object	DISCARD.up(Message msg)
java.lang.Object	Discovery.up(Message msg)
java.lang.Object	DROP.up(Message msg)
java.lang.Object	DUPL.up(Message msg)
java.lang.Object	Encrypt.up(Message msg)
java.lang.Object	EXAMPLE.up(Message msg)
java.lang.Object	Executing.up(Message msg)
java.lang.Object	FailureDetection.up(Message msg)
java.lang.Object	FD_SOCK.up(Message msg)
java.lang.Object	FD.up(Message msg)
java.lang.Object	FlowControl.up(Message msg)
java.lang.Object	FORK.up(Message msg)
java.lang.Object	FORWARD_TO_COORD.up(Message msg)
java.lang.Object	FRAG.up(Message msg)
java.lang.Object	FRAG2.up(Message msg)
java.lang.Object	FRAG3.up(Message msg)
java.lang.Object	HDRS.up(Message msg)
java.lang.Object	Locking.up(Message msg)
java.lang.Object	MAKE_BATCH.up(Message msg)
java.lang.Object	MERGE3.up(Message msg)
java.lang.Object	NAMING.up(Message msg)
java.lang.Object	PERF.up(Message msg)
java.lang.Object	RATE.up(Message msg)
java.lang.Object	RELAY.up(Message msg)	Deprecated.
java.lang.Object	REVERSE.up(Message msg)
java.lang.Object	RSVP.up(Message msg)
java.lang.Object	SASL.up(Message msg)	Deprecated.
java.lang.Object	SEQUENCER.up(Message msg)
java.lang.Object	SEQUENCER2.up(Message msg)
java.lang.Object	SERIALIZE.up(Message msg)
java.lang.Object	SHUFFLE.up(Message msg)
java.lang.Object	SIZE.up(Message msg)
java.lang.Object	SNIFF.up(Message msg)
java.lang.Object	STATS.up(Message msg)
java.lang.Object	STOMP.up(Message msg)
java.lang.Object	UNICAST3.up(Message msg)
java.lang.Object	VERIFY_SUSPECT.up(Message msg)

Method parameters in org.jgroups.protocols with type arguments of type Message

Modifier and Type	Method	Description
protected SHUFFLE	SHUFFLE.add(java.util.List<Message> queue, Message msg, java.util.concurrent.locks.Lock lock, java.util.function.Consumer<Message> send_function)
protected SHUFFLE	SHUFFLE.add(java.util.List<Message> queue, Message msg, java.util.concurrent.locks.Lock lock, java.util.function.Consumer<Message> send_function)
protected SHUFFLE	SHUFFLE.add(java.util.List<Message> queue, MessageBatch batch, java.util.concurrent.locks.Lock lock, java.util.function.Consumer<Message> send_function)
protected SHUFFLE	SHUFFLE.add(java.util.List<Message> queue, MessageBatch batch, java.util.concurrent.locks.Lock lock, java.util.function.Consumer<Message> send_function)
DROP	DROP.addDownFilter(java.util.function.Predicate<Message> filter)
protected void	UNICAST3.addQueuedMessages(Address sender, UNICAST3.ReceiverEntry entry, java.util.Collection<Message> queued_msgs)
DROP	DROP.addUpFilter(java.util.function.Predicate<Message> filter)
REVERSE	REVERSE.filter(java.util.function.Predicate<Message> f)
protected void	BARRIER.flushQueue(java.util.Map<Address,Message> queue)
protected void	UNICAST3.handleBatchReceived(UNICAST3.ReceiverEntry entry, Address sender, java.util.List<LongTuple<Message>> msgs, boolean oob)
protected java.lang.String	UNICAST3.printMessageList(java.util.List<LongTuple<Message>> list)
protected void	UNICAST3.processInternalMessage(Table<Message> win, Address sender)
protected void	SEQUENCER2.removeAndDeliver(Table<Message> win, Address sender)
protected void	UNICAST3.removeAndDeliver(Table<Message> win, Address sender)	Try to remove as many messages as possible from the table as pass them up.
DROP	DROP.removeDownFilter(java.util.function.Predicate<Message> filter)
DROP	DROP.removeUpFilter(java.util.function.Predicate<Message> filter)
protected SHUFFLE	SHUFFLE.reorderAndSend(java.util.List<Message> list, java.util.concurrent.locks.Lock lock, java.util.function.Consumer<Message> send_function)
protected SHUFFLE	SHUFFLE.reorderAndSend(java.util.List<Message> list, java.util.concurrent.locks.Lock lock, java.util.function.Consumer<Message> send_function)
protected void	BaseBundler.sendMessageList(Address dest, Address src, java.util.List<Message> list)
protected void	RemoveQueueBundler.sendMessageList(Address dest, Address src, java.util.List<Message> list)

Constructor parameters in org.jgroups.protocols with type arguments of type Message

Constructor	Description
Entry(short conn_id, Table<Message> msgs)
ReceiverEntry(Table<Message> received_msgs, short recv_conn_id)
RingBufferBundler(RingBuffer<Message> rb)
TransferQueueBundler(java.util.concurrent.BlockingQueue<Message> queue)

Uses of Message in org.jgroups.protocols.dns

Methods in org.jgroups.protocols.dns with parameters of type Message

Modifier and Type	Method	Description
protected void	DNS_PING.sendDiscoveryRequest(Message req)

Uses of Message in org.jgroups.protocols.pbcast

Fields in org.jgroups.protocols.pbcast declared as Message

Modifier and Type	Field	Description
protected static Message	NAKACK2.DUMMY_OOB_MSG

Fields in org.jgroups.protocols.pbcast with type parameters of type Message

Modifier and Type	Field	Description
protected static java.util.function.BiConsumer<MessageBatch,Message>	NAKACK2.BATCH_ACCUMULATOR
protected BoundedList<Message>	NAKACK2.become_server_queue
protected static java.util.function.Predicate<Message>	NAKACK2.dont_loopback_filter
protected java.util.function.Predicate<Message>	NAKACK2.no_dummy_and_no_oob_delivered_msgs_and_no_dont_loopback_msgs
protected java.util.concurrent.ConcurrentMap<Address,Table<Message>>	NAKACK2.xmit_table	Map to store sent and received messages (keyed by sender)

Methods in org.jgroups.protocols.pbcast that return Message

Modifier and Type	Method	Description
protected Message	NAKACK2.msgFromXmitRsp(Message msg, NakAckHeader2 hdr)

Methods in org.jgroups.protocols.pbcast that return types with arguments of type Message

Modifier and Type	Method	Description
protected Table<Message>	NAKACK2.createTable(long initial_seqno)
Table<Message>	NAKACK2.getWindow(Address sender)	Returns the receive window for sender; only used for testing.

Methods in org.jgroups.protocols.pbcast with parameters of type Message

Modifier and Type	Method	Description
protected void	NAKACK2.deliver(Message msg, Address sender, long seqno, java.lang.String error_msg)
java.lang.Object	FLUSH.down(Message msg)
java.lang.Object	NAKACK2.down(Message msg)
java.lang.Object	STABLE.down(Message msg)
protected void	NAKACK2.handleMessage(Message msg, NakAckHeader2 hdr)	Finds the corresponding retransmit buffer and adds the message to it (according to seqno).
protected void	STABLE.handleRegularMessage(Message msg)
protected void	NAKACK2.handleXmitRsp(Message msg, NakAckHeader2 hdr)
protected Message	NAKACK2.msgFromXmitRsp(Message msg, NakAckHeader2 hdr)
protected void	NAKACK2.queueMessage(Message msg, long seqno)
protected void	NAKACK2.send(Message msg)	Adds the message to the sent_msgs table and then passes it down the stack.
protected void	NAKACK2.sendXmitRsp(Address dest, Message msg)	Sends a message msg to the requester.
java.lang.Object	FLUSH.up(Message msg)
java.lang.Object	GMS.up(Message msg)
java.lang.Object	NAKACK2.up(Message msg)
java.lang.Object	STABLE.up(Message msg)
java.lang.Object	STATE_TRANSFER.up(Message msg)
java.lang.Object	StreamingStateTransfer.up(Message msg)

Method parameters in org.jgroups.protocols.pbcast with type arguments of type Message

Modifier and Type	Method	Description
protected void	NAKACK2.handleMessages(Address dest, Address sender, java.util.List<LongTuple<Message>> msgs, boolean oob, AsciiString cluster_name)
protected void	NAKACK2.removeAndDeliver(Table<Message> buf, Address sender, boolean loopback, AsciiString cluster_name)	Efficient way of checking whether another thread is already processing messages from sender.
protected static long	NAKACK2.sizeOfAllMessages(Table<Message> buf, boolean include_headers)

Uses of Message in org.jgroups.protocols.relay

Methods in org.jgroups.protocols.relay that return Message

Modifier and Type	Method	Description
protected Message	RELAY2.copy(Message msg)	Copies the message, but only the headers above the current protocol (RELAY) (or RpcDispatcher related headers)
protected Message	Route.createMessage(Address target, Address final_destination, Address original_sender, Message msg)

Methods in org.jgroups.protocols.relay with parameters of type Message

Modifier and Type	Method	Description
protected Message	RELAY2.copy(Message msg)	Copies the message, but only the headers above the current protocol (RELAY) (or RpcDispatcher related headers)
protected Message	Route.createMessage(Address target, Address final_destination, Address original_sender, Message msg)
protected void	RELAY2.deliver(Address dest, Address sender, Message msg)
protected void	RELAY2.deliverLocally(SiteAddress dest, SiteAddress sender, Message msg)
java.lang.Object	RELAY2.down(Message msg)
protected void	RELAY2.forwardTo(Address next_dest, SiteAddress final_dest, Address original_sender, Message msg, boolean forward_to_current_coord)
protected void	RELAY2.handleMessage(RELAY2.Relay2Header hdr, Message msg)	Called to handle a message received by the transport
protected void	RELAY2.handleRelayMessage(RELAY2.Relay2Header hdr, Message msg)	Called to handle a message received by the relayer
void	Relayer.Bridge.receive(Message msg)
protected void	RELAY2.route(SiteAddress dest, SiteAddress sender, Message msg)	Routes the message to the target destination, used by a site master (coordinator)
void	Route.send(Address final_destination, Address original_sender, Message msg)
protected void	RELAY2.sendToBridges(Address sender, Message msg, java.lang.String... excluded_sites)	Sends the message via all bridges excluding the excluded_sites bridges
java.lang.Object	RELAY2.up(Message msg)

Uses of Message in org.jgroups.protocols.rules

Methods in org.jgroups.protocols.rules with parameters of type Message

Modifier and Type	Method	Description
java.lang.Object	EventHandler.down(Message msg)
java.lang.Object	SUPERVISOR.down(Message msg)	Deprecated.
java.lang.Object	EventHandler.up(Message msg)

Uses of Message in org.jgroups.protocols.tom

Methods in org.jgroups.protocols.tom that return types with arguments of type Message

Modifier and Type	Method	Description
java.util.List<Message>	DeliveryManager.getNextMessagesToDeliver()	returns an ordered list with the messages to be deliver.
java.util.List<Message>	DeliveryManagerImpl.getNextMessagesToDeliver()

Methods in org.jgroups.protocols.tom with parameters of type Message

Modifier and Type	Method	Description
void	DeliveryProtocol.deliver(Message message)	deliver a message
void	TOA.deliver(Message message)
java.lang.Object	TOA.down(Message message)
java.lang.Object	TOA.up(Message message)

Uses of Message in org.jgroups.stack

Fields in org.jgroups.stack with type parameters of type Message

Modifier and Type	Field	Description
protected static java.util.function.BiConsumer<java.lang.Short,Message>	GossipRouter.MSG_CONSUMER

Methods in org.jgroups.stack with parameters of type Message

Modifier and Type	Method	Description
protected boolean	Protocol.accept(Message msg)	Called by the default implementation of Protocol.up(org.jgroups.util.MessageBatch) for each message to determine if the message should be removed from the message batch (and handled by the current protocol) or not.
java.lang.Object	Protocol.down(Message msg)	A message is sent down the stack.
java.lang.Object	ProtocolStack.down(Message msg)
void	MessageProcessingPolicy.loopback(Message msg, boolean oob, boolean internal)	Process a message that was not received from the transport but from above (e.g.
void	MessageProcessingPolicy.process(Message msg, boolean oob, boolean internal)	Process a message received from the transport
java.lang.Object	Protocol.up(Message msg)	A single message was received.
java.lang.Object	ProtocolStack.up(Message msg)

Uses of Message in org.jgroups.util

Fields in org.jgroups.util declared as Message

Modifier and Type	Field	Description
protected Message[]	MessageBatch.messages	The storage of the messages; removed messages have a null element
protected Message	SubmitToThreadPool.SingleLoopbackHandler.msg
protected Message	SubmitToThreadPool.SingleMessageHandler.msg

Fields in org.jgroups.util with type parameters of type Message

Modifier and Type	Field	Description
protected java.util.NavigableMap<java.lang.Long,Message>	ForwardQueue.forward_table	Maintains messages forwarded to the target which which no ack has been received yet.
protected static java.util.function.ToIntBiFunction<Message,MessageBatch>	MessageBatch.length_visitor
protected java.util.Map<Address,java.util.Queue<Message>>	MessageCache.map
protected SizeBoundedQueue<Message>	NonBlockingCredit.msg_queue
protected SizeBoundedQueue<Message>	NonBlockingCreditMap.msg_queue
protected static java.util.function.Consumer<Message>	NonBlockingCredit.NO_OP_SEND_FUNCTION
protected static java.util.function.Consumer<Message>	NonBlockingCreditMap.NO_OP_SEND_FUNCTION
protected java.util.function.Consumer<Message>	NonBlockingCredit.send_function
protected java.util.function.Consumer<Message>	NonBlockingCreditMap.send_function
protected static java.util.function.ToLongBiFunction<Message,MessageBatch>	MessageBatch.total_size_visitor

Methods in org.jgroups.util that return Message

Modifier and Type	Method	Description
Message[]	MessageBatch.array()	Returns the underlying message array.
static Message	Util.byteBufferToMessage(byte[] buffer, int offset, int length)
Message	MessageBatch.first()
Message	MessageBatch.last()
Message	MessageBatch.BatchIterator.next()
static Message	Util.readMessage(java.io.DataInput instream)

Methods in org.jgroups.util that return types with arguments of type Message

Modifier and Type	Method	Description
java.util.Collection<Message>	MessageCache.drain(Address sender)
java.util.Collection<Message>	MessageBatch.getMatchingMessages(short id, boolean remove)	Removes and returns all messages which have a header with ID == id
static java.util.List<Message>	Util.readMessageList(java.io.DataInput in, short transport_id)
java.util.stream.Stream<Message>	MessageBatch.stream()

Methods in org.jgroups.util with parameters of type Message

Modifier and Type	Method	Description
MessageBatch	MessageBatch.add(Message msg)
int	MessageBatch.add(Message msg, boolean resize)	Adds a message to the table
MessageCache	MessageCache.add(Address sender, Message msg)
protected boolean	NonBlockingCredit.addToQueue(Message msg, int length)
protected boolean	NonBlockingCreditMap.addToQueue(Message msg, int length)
protected boolean	MaxOneThreadPerSender.Entry.allowedToSubmitToThreadPool(Message msg)	Either allows access to submit a task to the thread pool for delivery to the application, or queues the message
boolean	CreditMap.decrement(Message msg, int credits, long timeout)	Decrements credits bytes from all.
boolean	NonBlockingCreditMap.decrement(Message msg, int credits, long timeout)
boolean	Credit.decrementIfEnoughCredits(Message msg, int credits, long timeout)
boolean	NonBlockingCredit.decrementIfEnoughCredits(Message msg, int credits, long timeout)	Decrements the sender's credits by the size of the message.
void	MaxOneThreadPerSender.loopback(Message msg, boolean oob, boolean internal)
void	SubmitToThreadPool.loopback(Message msg, boolean oob, boolean internal)
static Buffer	Util.messageToByteBuffer(Message msg)
protected void	MaxOneThreadPerSender.Entry.process(Message msg, boolean loopback)
protected void	MaxOneThreadPerSender.MessageTable.process(Message msg, boolean loopback)
void	MaxOneThreadPerSender.process(Message msg, boolean oob, boolean internal)
void	SubmitToThreadPool.process(Message msg, boolean oob, boolean internal)
void	ForwardQueue.receive(long id, Message msg)
void	MyReceiver.receive(Message msg)
MessageBatch	MessageBatch.remove(Message msg)	Removes the current message (found by indentity (==)) by nulling it in the message array
void	MessageBatch.BatchIterator.replace(Message msg)
MessageBatch	MessageBatch.replace(java.util.function.Predicate<Message> filter, Message replacement, boolean match_all)	Replaces all messages which match a given filter with a replacement message
MessageBatch	MessageBatch.replace(Message existing_msg, Message new_msg)	Replaces a message in the batch with another one
void	MessageIterator.replace(Message msg)	Replaces the message at the current index with msg
int	MessageBatch.replaceIf(java.util.function.Predicate<Message> filter, Message replacement, boolean match_all)	Replaces all messages that match a given filter with a replacement message
void	ForwardQueue.send(long id, Message msg)
protected void	MaxOneThreadPerSender.Entry.submit(Message msg, boolean loopback)
static void	Util.writeMessage(Message msg, java.io.DataOutput dos, boolean multicast)

Method parameters in org.jgroups.util with type arguments of type Message

Modifier and Type	Method	Description
void	MessageBatch.forEach(java.util.function.BiConsumer<Message,MessageBatch> consumer)
<T> java.util.Collection<T>	MessageBatch.map(java.util.function.BiFunction<Message,MessageBatch,T> visitor)	Applies a function to all messages and returns a list of the function results
static void	Util.parse(byte[] buf, int offset, int length, java.util.function.BiConsumer<java.lang.Short,Message> msg_consumer, java.util.function.BiConsumer<java.lang.Short,MessageBatch> batch_consumer, boolean tcp)
static void	Util.parse(java.io.InputStream input, java.util.function.BiConsumer<java.lang.Short,Message> msg_consumer, java.util.function.BiConsumer<java.lang.Short,MessageBatch> batch_consumer, boolean tcp)
static void	Util.parse(java.lang.String filename, java.util.function.BiConsumer<java.lang.Short,Message> msg_consumer, java.util.function.BiConsumer<java.lang.Short,MessageBatch> batch_consumer, boolean tcp)
MessageBatch	MessageBatch.remove(java.util.function.Predicate<Message> filter)	Removes all messages which match filter
MessageBatch	MessageBatch.replace(java.util.function.Predicate<Message> filter, Message replacement, boolean match_all)	Replaces all messages which match a given filter with a replacement message
int	MessageBatch.replaceIf(java.util.function.Predicate<Message> filter, Message replacement, boolean match_all)	Replaces all messages that match a given filter with a replacement message
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, java.util.List<Message> msgs, java.io.DataOutput dos, boolean multicast, short transport_id)	Write a list of messages with the *same* destination and src addresses.

Constructors in org.jgroups.util with parameters of type Message

Constructor	Description
SingleLoopbackHandler(Message msg)
SingleMessageHandler(Message msg)
SingleMessageHandlerWithClusterName(Message msg, byte[] cluster_name)

Constructor parameters in org.jgroups.util with type arguments of type Message

Constructor	Description
MessageBatch(java.util.Collection<Message> msgs)
MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, java.util.Collection<Message> msgs)
MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, java.util.Collection<Message> msgs, java.util.function.Predicate<Message> filter)
MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, java.util.Collection<Message> msgs, java.util.function.Predicate<Message> filter)
NonBlockingCredit(long credits, int max_size, java.util.concurrent.locks.Lock lock, java.util.function.Consumer<Message> send_function)
NonBlockingCreditMap(long max_credits, int max_size, java.util.concurrent.locks.Lock lock, java.util.function.Consumer<Message> send_function)