Uses of Interface
org.jgroups.Message

Packages that use Message

Package	Description
org.jgroups	Provides top-level public JGroups classes such as Channel, Message, etc.
org.jgroups.admin
org.jgroups.auth
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.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

Classes in org.jgroups that implement Message

Modifier and Type	Class	Description
class	BaseMessage	A common superclass for all Message implementations.
class	BatchMessage	A message that contains a batch of messages.
class	BytesMessage	A Message containing a byte array as payload.
class	CompositeMessage	A message composed of multiple messages.
class	EmptyMessage	A Message without a payload; optimized for sending only headers (e.g.
class	FragmentedMessage	A message which refers to another message, but only marshals (Streamable.writeTo(DataOutput)) a part of the original message, starting at a given BytesMessage.offset and marshalling only BytesMessage.length bytes.
class	LongMessage	Message with a long as payload.
class	NioMessage	A Message with a (heap-based or direct) ByteBuffer as payload. Note that the payload of an NioMessage must not be modified after sending it (ie.
class	ObjectMessage	A Message with an object as payload.

Subinterfaces with type arguments of type Message in org.jgroups

Modifier and Type	Interface	Description
interface	Message	A Message is used to send data to members of a group.

Classes in org.jgroups that implement interfaces with type arguments of type Message

Modifier and Type	Class	Description
class	BatchMessage	A message that contains a batch of messages.
protected class	BatchMessage.BatchMessageIterator
class	CompositeMessage	A message composed of multiple messages.
protected class	CompositeMessage.CompositeMessageIterator

Fields in org.jgroups declared as Message

Modifier and Type	Field	Description
protected Message[]	BatchMessage.msgs
protected Message[]	CompositeMessage.msgs
protected Message	FragmentedMessage.original_msg

Fields in org.jgroups with type parameters of type Message

Modifier and Type	Field	Description
protected static Map<Short, Supplier<? extends Message>>	MessageFactory.map

Methods in org.jgroups with type parameters of type Message

Modifier and Type	Method	Description
static <T extends Message> T	MessageFactory.create(short type)	Creates a message based on the given ID
<T extends Message> T	BatchMessage.get(int index)
<T extends Message> T	CompositeMessage.get(int index)

Methods in org.jgroups that return Message

Modifier and Type	Method	Description
Message	BaseMessage.clearFlag(Message.Flag... flags)	Clears a number of flags in a message
Message	BaseMessage.clearFlag(Message.TransientFlag... flags)
Message	Message.clearFlag(Message.Flag... flags)	Removes a number of flags from the message.
Message	Message.clearFlag(Message.TransientFlag... flags)	Removes a number of transient flags from the message.
Message	BaseMessage.clearHeaders()	Removes all headers: use carefully!
Message	Message.clearHeaders()	Removes all headers: use carefully!
Message	BaseMessage.copy(boolean copy_payload, boolean copy_headers)	Copies the source- and destination addresses, flags and headers (if copy_headers is true). If copy_payload is set, then method BaseMessage.copyPayload(Message) of the subclass will be called, which is responsible for copying the payload specific to that message type. Note that for headers, only the arrays holding references to the headers are copied, not the headers themselves ! The consequence is that the headers array of the copy hold the *same* references as the original, so do *not* modify the headers ! If you want to change a header, copy it and call Message.putHeader(short,Header) again.
Message	Message.copy(boolean copy_payload, boolean copy_headers)	Copies a message
protected Message	BaseMessage.copyPayload(Message copy)	Copies the payload
protected Message	BytesMessage.copyPayload(Message copy)	Copies the byte array.
protected Message	FragmentedMessage.copyPayload(Message copy)
protected Message	LongMessage.copyPayload(Message copy)
protected Message	NioMessage.copyPayload(Message copy)
protected Message	ObjectMessage.copyPayload(Message copy)
default Message	Message.dest(Address new_dest)
protected Message	BatchMessage.ensureSameDest(Message msg)
protected Message	CompositeMessage.ensureSameDest(Message msg)
Message[]	BatchMessage.getMessages()
Message	FragmentedMessage.getOriginalMessage()
Message	BaseMessage.headers(Header[] hdrs)
Message	BatchMessage.BatchMessageIterator.next()
Message	CompositeMessage.CompositeMessageIterator.next()
Message	BaseMessage.putHeader(short id, Header hdr)	Puts a header given an ID into the hashmap.
protected Message	BaseMessage.putHeader(short id, Header hdr, boolean replace_if_present)
Message	Message.putHeader(short id, Header hdr)	Adds a header to the message
Message	BaseMessage.putHeaderIfAbsent(short id, Header hdr)
Message	Message.putHeaderIfAbsent(short id, Header hdr)	Adds a header to a message if not present
default Message	Message.setArray(byte[] b)
Message	Message.setArray(byte[] b, int offset, int length)	Sets the byte array in a message. Throws an exception if the message does not have a byte[] array payload (Message.hasArray() is false). Note that this is a convenience method, as most messages are of type BytesMessage.
Message	Message.setArray(ByteArray buf)	Sets the byte array in a message. Throws an exception if the message does not have a byte[] array payload (Message.hasArray() is false). Note that this is a convenience method, as most messages are of type BytesMessage.
Message	BaseMessage.setDest(Address new_dest)
Message	Message.setDest(Address new_dest)	Sets the destination address to send the message to.
Message	BaseMessage.setFlag(short flag, boolean transient_flags, boolean xor)
Message	BaseMessage.setFlag(Message.Flag... flags)	Sets a number of flags in a message
Message	BaseMessage.setFlag(Message.TransientFlag... flags)	Same as BaseMessage.setFlag(Flag...) except that transient flags are not marshalled
default Message	Message.setFlag(short flag, boolean transient_flags)	Sets the flags as a short; this way, multiple flags can be set in one operation
Message	Message.setFlag(short flag, boolean transient_flags, boolean xor)	Sets the flags as a short; this way, multiple flags can be set in one operation
Message	Message.setFlag(Message.Flag... flags)	Sets one or more flags (xor-ing existing flags)
Message	Message.setFlag(Message.TransientFlag... flags)	Sets one or more transient flags (xor-ing).
Message	Message.setObject(Object obj)	Sets an object in a message.
Message	BaseMessage.setPayload(Object pl)
Message	Message.setPayload(Object pl)	Sets the payload
Message	BaseMessage.setSrc(Address new_src)
Message	Message.setSrc(Address new_src)	Sets the address of the sender of this message
default Message	Message.src(Address new_src)

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

Modifier and Type	Method	Description
Supplier<Message>	BatchMessage.create()
Supplier<Message>	BytesMessage.create()
Supplier<Message>	CompositeMessage.create()
Supplier<Message>	EmptyMessage.create()
Supplier<Message>	FragmentedMessage.create()
Supplier<? extends Message>	LongMessage.create()
Supplier<Message>	NioMessage.create()
Supplier<Message>	ObjectMessage.create()
Iterator<Message>	BatchMessage.iterator()
Iterator<Message>	CompositeMessage.iterator()

Methods in org.jgroups with parameters of type Message

Modifier and Type	Method	Description
BatchMessage	BatchMessage.add(Message msg)	Adds the message at the end of the array.
BatchMessage	BatchMessage.add(Message... messages)
CompositeMessage	CompositeMessage.add(Message msg)	Adds the message at the end of the array.
CompositeMessage	CompositeMessage.add(Message... messages)
protected Message	BaseMessage.copyPayload(Message copy)	Copies the payload
protected Message	BytesMessage.copyPayload(Message copy)	Copies the byte array.
protected Message	FragmentedMessage.copyPayload(Message copy)
protected Message	LongMessage.copyPayload(Message copy)
protected Message	NioMessage.copyPayload(Message copy)
protected Message	ObjectMessage.copyPayload(Message copy)
Object	JChannel.down(Message msg)
CompletableFuture<Object>	JChannel.down(Message msg, boolean async)	Sends a message down asynchronously.
protected Message	BatchMessage.ensureSameDest(Message msg)
protected Message	CompositeMessage.ensureSameDest(Message msg)
default void	Receiver.receive(Message msg)	Called when a message is received.
JChannel	JChannel.send(Message msg)	Sends a message.
Object	JChannel.up(Message msg)
Object	UpHandler.up(Message msg)

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

Modifier and Type	Method	Description
CompositeMessage	CompositeMessage.add(Collection<Message> messages)
static void	MessageFactory.register(short type, Supplier<? extends Message> generator)	Registers a new creator of messages

Constructors in org.jgroups with parameters of type Message

Modifier	Constructor	Description
	BatchMessage(Address dest, Address src, Message[] msgs, int index)
	CompositeMessage(Address dest, Message... messages)
	FragmentedMessage(Message original_msg, int off, int len)

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

Modifier	Constructor	Description
	CompositeMessage(Address dest, Collection<Message> messages)

Uses of Message in org.jgroups.admin

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

Modifier and Type	Method	Description
void	Admin.handleAdminMessage(Message msg, AdminHeader hdr)
protected void	Admin.handleExec(Message msg, AdminHeader hdr)
protected void	Admin.handleInternalAdminMessage(Message msg, AdminHeader hdr)
protected void	Admin.handleInternalRequest(Message msg)
protected void	Admin.handleInternalResponse(Message msg, AdminHeader hdr)
void	AdminHandler.handleMessage(Message msg, AdminHeader hdr)
abstract void	AdminHandler.handleRequest(Message msg, AdminHeader hdr)
void	PartitionHandler.handleRequest(Message msg, AdminHeader hdr)
void	ProbeAdminHandler.handleRequest(Message msg, AdminHeader ignored)
void	SwitchAdminHandler.handleRequest(Message msg, AdminHeader hdr)
abstract void	AdminHandler.handleResponse(Message msg, AdminHeader hdr)
void	PartitionHandler.handleResponse(Message msg, AdminHeader hdr)
void	ProbeAdminHandler.handleResponse(Message msg, AdminHeader ignored)
void	SwitchAdminHandler.handleResponse(Message msg, AdminHeader hdr)
void	AdminHandler.sendRequest(String key, Message msg)
void	AdminHandler.sendRequest(String key, Message msg, String command)
void	AdminHandler.sendResponse(String key, Message msg)
void	AdminHandler.sendResponse(String key, Message msg, String command)

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)
boolean	Krb5Token.authenticate(AuthToken token, Message msg)
boolean	RegexMembership.authenticate(AuthToken token, Message msg)
boolean	X509Token.authenticate(AuthToken token, Message msg)

Uses of Message in org.jgroups.blocks

Fields in org.jgroups.blocks declared as Message

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

Methods in org.jgroups.blocks that return Message

Modifier and Type	Method	Description
protected static Message	RequestCorrelator.makeReply(Message msg)

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

Modifier and Type	Method	Description
protected <T> UnicastRequest<T>	MessageDispatcher._sendMessage(Message msg, RequestOptions opts)
protected <T> GroupRequest<T>	MessageDispatcher.cast(Collection<Address> dests, Message msg, RequestOptions options, boolean block_for_results)
<T> RspList<T>	MessageDispatcher.castMessage(Collection<Address> dests, Message msg, RequestOptions opts)	Sends a message to all members and expects responses from members in dests (if non-null).
<T> CompletableFuture<RspList<T>>	MessageDispatcher.castMessageWithFuture(Collection<Address> dests, Message msg, RequestOptions opts)	Sends a message to all members and expects responses from members in dests (if non-null).
protected void	RequestCorrelator.dispatch(Message msg, RequestCorrelator.Header hdr)
Object	MessageDispatcher.ProtocolAdapter.down(Message msg)
T	Request.execute(Message msg, boolean block_for_results)
Object	MessageDispatcher.handle(Message msg)
void	MessageDispatcher.handle(Message request, Response response)
Object	RequestHandler.handle(Message msg)	Processes a request synchronously, ie.
default void	RequestHandler.handle(Message request, Response response)	Processes a request asynchronously.
Object	RpcDispatcher.handle(Message req)	Message contains MethodCall.
protected void	RequestCorrelator.handleRequest(Message req, RequestCorrelator.Header hdr)	Handle a request msg for this correlator
protected void	RequestCorrelator.handleResponse(Message rsp, RequestCorrelator.Header hdr)
protected static Message	RequestCorrelator.makeReply(Message msg)
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.sendAnycastRequest(Message req, Collection<Address> dest_mbrs)
<T> T	MessageDispatcher.sendMessage(Message msg, RequestOptions opts)	Sends a unicast message and - depending on the options - returns a result
<T> CompletableFuture<T>	MessageDispatcher.sendMessageWithFuture(Message msg, RequestOptions opts)	Sends a unicast message to the target defined by msg.getDest() and returns a future
<T> void	RequestCorrelator.sendMulticastRequest(Collection<Address> dest_mbrs, Message msg, Request<T> req, RequestOptions opts)	Sends a request to a group.
protected void	RequestCorrelator.sendReply(Message req, long req_id, Object reply, boolean is_exception)
void	GroupRequest.sendRequest(Message msg)
protected void	GroupRequest.sendRequest(Message msg, Collection<Address> targetMembers)
abstract void	Request.sendRequest(Message req)
void	UnicastRequest.sendRequest(Message msg)
protected void	RequestCorrelator.sendResponse(Message rsp, long req_id, boolean is_exception)
<T> void	RequestCorrelator.sendUnicastRequest(Message msg, Request<T> req, RequestOptions opts)	Sends a request to a single destination
Object	MessageDispatcher.ProtocolAdapter.up(Message msg)

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

Modifier	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
Object	ForkChannel.down(Message msg)
Object	ForkProtocol.down(Message msg)
Object	ForkProtocolStack.down(Message msg)
Object	UnknownForkHandler.handleUnknownForkChannel(Message message, String forkChannelId)	Handle a message that refers to an unknown fork channel
Object	UnknownForkHandler.handleUnknownForkStack(Message message, String forkStackId)	Handle a message that refers to an unknown fork stack
ForkChannel	ForkChannel.send(Message msg)
protected void	ForkChannel.setHeader(Message msg)
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 static final Message	ReliableMulticast.DUMMY_OOB_MSG
protected static final Message	ReliableUnicast.DUMMY_OOB_MSG
protected static final Message	UNICAST3.DUMMY_OOB_MSG
protected final Message[]	FRAG2.FragEntry.fragments
protected Message	FRAG3.FragEntry.msg

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

Modifier and Type	Field	Description
protected static final BiConsumer<MessageBatch, Message>	ReliableMulticast.BATCH_ACCUMULATOR
protected static final BiConsumer<MessageBatch, Message>	ReliableUnicast.BATCH_ACCUMULATOR
protected static final BiConsumer<MessageBatch, Message>	SEQUENCER2.BATCH_ACCUMULATOR
protected static final BiConsumer<MessageBatch, Message>	UNICAST3.BATCH_ACCUMULATOR
protected Queue<Message>	ReliableMulticast.become_server_queue
protected final Buffer<Message>	ReliableMulticast.Entry.buf
protected final Buffer<Message>	ReliableUnicast.Entry.buf
protected static final Predicate<Message>	UNICAST3.dont_loopback_filter
protected final List<Predicate<Message>>	DROP.down_filters
protected List<Message>	SHUFFLE.down_msgs
protected final BlockingQueue<Message>	BATCH2.down_queue
protected final Predicate<Message>	ReliableUnicast.drop_oob_and_dont_loopback_msgs_filter
protected final Predicate<Message>	UNICAST3.drop_oob_and_dont_loopback_msgs_filter
protected Predicate<Message>	HDRS.filter
protected Predicate<Message>	REVERSE.filter
protected Predicate<Message>	REVERSE2.filter
protected final NavigableMap<Long,Message>	SEQUENCER.forward_table	Maintains messages forwarded to the coord which which no ack has been received yet.
protected final Function<Address, List<Message>>	BaseBundler.FUNC
protected static final Function<? super String, ? extends List<Message>>	FORK.FUNC
protected final BlockingQueue<Message>	SEQUENCER2.fwd_queue
protected final Predicate<Message>	FRAG.HAS_FRAG_HEADER
protected final Predicate<Message>	FRAG2.HAS_FRAG_HEADER
protected final Predicate<Message>	FRAG3.HAS_FRAG_HEADER
protected final Predicate<Message>	FailureDetection.HAS_HEADER
protected final Predicate<Message>	ReliableMulticast.HAS_HEADER
protected Buffer<Message>	ReliableMulticast.local_xmit_table
protected final Map<Address,Message>	BARRIER.mcast_queue
protected final Map<Address, List<Message>>	BaseBundler.msgs	Keys are destinations, values are lists of Messages
protected final Table<Message>	UNICAST3.Entry.msgs
protected final Predicate<Message>	ReliableMulticast.no_dummy_and_no_oob_delivered_msgs_and_no_dont_loopback_msgs
protected final Map<Address, List<Message>>	MAKE_BATCH.oob_map_mcast
protected final Map<Address, List<Message>>	MAKE_BATCH.oob_map_ucast
protected final Deque<Message>	REVERSE.queue
protected final Deque<Message>	REVERSE2.queue
protected BlockingQueue<Message>	TransferQueueBundler.queue
protected Table<Message>	SEQUENCER2.received_msgs
protected final Map<Address, List<Message>>	MAKE_BATCH.reg_map_mcast
protected final Map<Address, List<Message>>	MAKE_BATCH.reg_map_ucast
protected static final Predicate<Message>	ReliableMulticast.remove_filter
protected static final Predicate<Message>	ReliableUnicast.remove_filter
protected final List<Message>	BATCH2.remove_queue
protected List<Message>	TransferQueueBundler.remove_queue
protected final Function<Message,Long>	ReliableMulticast.SEQNO_GETTER
protected final Map<Address,Message>	BARRIER.ucast_queue
protected final List<Predicate<Message>>	DROP.up_filters
protected List<Message>	SHUFFLE.up_msgs

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

Modifier and Type	Method	Description
<T extends Buffer<Message>> T	ReliableMulticast.getBuf(Address sender)	Returns the receive window for sender; only used for testing.

Methods in org.jgroups.protocols that return Message

Modifier and Type	Method	Description
protected Message	Encrypt._decrypt(Cipher cipher, Key key, Message msg, EncryptHeader hdr)
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.assembleMessage(Message[] fragments, boolean needs_deserialization, FragHeader hdr)	Assembles all the message fragments into one message.
protected Message	FRAG3.FragEntry.assembleMessage()	Assembles all the fragments into one buffer.
protected Message	FRAG4.assembleMessage(Message[] fragments, boolean needs_deserialization, FragHeader hdr)
protected Message	Encrypt.decrypt(Cipher cipher, Message msg)	Does the actual work for decrypting - if version does not match current cipher then tries the previous cipher
protected Message	SERIALIZE.deserialize(Address sender, byte[] buf, int offset, int length)
protected Message	Encrypt.encrypt(Message msg)
protected static Message	COMPRESS.messageFromByteArray(byte[] uncompressed_payload)
protected Message	ReliableMulticast.msgFromXmitRsp(Message msg, NakAckHeader hdr)
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, boolean needs_deserialization)	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
protected Queue<Message>	ReliableMulticast.becomeServerQueue()
protected Buffer<Message>	ReliableMulticast.Entry.buf()
Buffer<Message>	ReliableUnicast.Entry.buf()
protected abstract Buffer<Message>	ReliableUnicast.createBuffer(long initial_seqno)
protected Buffer<Message>	UNICAST4.createBuffer(long s)
protected Table<Message>	UNICAST3.createTable(long seqno)
protected Buffer<Message>	NAKACK3.createXmitWindow(long initial_seqno)
protected Buffer<Message>	NAKACK4.createXmitWindow(long initial_seqno)
protected abstract Buffer<Message>	ReliableMulticast.createXmitWindow(long initial_seqno)
Predicate<Message>	REVERSE.filter()
Predicate<Message>	REVERSE2.filter()
Table<Message>	UNICAST3.getSendWindow(Address target)	Used for testing only!
protected Buffer<Message>	ReliableMulticast.sendBuf()

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

Modifier and Type	Method	Description
protected Message	Encrypt._decrypt(Cipher cipher, Key key, Message msg, EncryptHeader hdr)
protected Object	BATCH2._down(Message msg)
protected SHUFFLE	SHUFFLE.add(List<Message> queue, Message msg, Lock lock, Consumer<Message> send_function)
protected void	PerDestinationBundler.SendBuffer.addAndSendIfSizeExceeded(Message msg)
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, int size)
protected boolean	BATCH2.Buffer.addMessage(Message msg)
protected void	PerDestinationBundler.SendBuffer.addMessage(Message msg, int size)
protected void	ReliableUnicast.addMessage(ReliableUnicast.ReceiverEntry entry, Address sender, long seqno, Message msg)
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	SIZE2.addSample(Message msg, DistributionSampler ds)
protected boolean	NAKACK4.addToSendBuffer(Buffer<Message> win, long seq, Message msg, Predicate<Message> filter)
protected boolean	ReliableMulticast.addToSendBuffer(Buffer<Message> win, long seq, Message msg, Predicate<Message> filter)	Adds the message to the send buffer.
protected boolean	ReliableUnicast.addToSendBuffer(Buffer<Message> win, long seq, Message msg, Predicate<Message> filter)	Adds the message to the send buffer.
protected Message	FRAG2.assembleMessage(Message[] fragments, boolean needs_deserialization, FragHeader hdr)	Assembles all the message fragments into one message.
protected Message	FRAG4.assembleMessage(Message[] fragments, boolean needs_deserialization, FragHeader hdr)
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.decrypt(Cipher cipher, Message msg)	Does the actual work for decrypting - if version does not match current cipher then tries the previous cipher
protected void	ReliableMulticast.deliver(Message msg, Address sender, long seqno, ReliableMulticast.Entry entry, String error_msg)
protected void	SEQUENCER.deliver(Message msg, SEQUENCER.SequencerHeader hdr)
protected void	SEQUENCER2.deliver(Message msg, SEQUENCER2.SequencerHeader hdr)
protected void	ReliableUnicast.deliverMessage(Message msg, Address sender, long seqno)
protected void	UNICAST3.deliverMessage(Message msg, Address sender, long seqno)
void	PerDestinationBundler.doSend(Message msg)
Object	ASYM_ENCRYPT.down(Message msg)
Object	AUTH.down(Message msg)
Object	BATCH2.down(Message msg)
Object	CLEAR_FLAGS.down(Message msg)
Object	COMPRESS.down(Message msg)	We compress the payload if it is larger than min_size.
Object	DAISYCHAIN.down(Message msg)
Object	DELAY.down(Message msg)
Object	DISCARD_PAYLOAD.down(Message msg)
Object	DISCARD.down(Message msg)
Object	DROP.down(Message msg)
Object	DUPL.down(Message msg)
Object	Encrypt.down(Message msg)
Object	EXAMPLE.down(Message msg)
Object	FailureDetection.down(Message msg)
Object	FlowControl.down(Message msg)
Object	FRAG.down(Message msg)
Object	FRAG2.down(Message msg)
Object	FRAG3.down(Message msg)
Object	HDRS.down(Message msg)
Object	NON_BLOCKING_SENDS.down(Message msg)
Object	PERF.down(Message msg)
Object	RATE_LIMITER.down(Message msg)
Object	RATE_LIMITER2.down(Message msg)
Object	RATE.down(Message msg)
Object	RED.down(Message msg)	Deprecated, for removal: This API element is subject to removal in a future version.
Object	ReliableMulticast.down(Message msg)
Object	ReliableUnicast.down(Message msg)
Object	RSVP.down(Message msg)
Object	SEQUENCER.down(Message msg)
Object	SEQUENCER2.down(Message msg)
Object	SERIALIZE.down(Message msg)
Object	SHUFFLE.down(Message msg)
Object	SIZE.down(Message msg)
Object	SIZE2.down(Message msg)
CompletableFuture<Object>	SIZE2.down(Message msg, boolean async)
Object	SNIFF.down(Message msg)
Object	STATS.down(Message msg)
Object	THREAD_COUNT.down(Message msg)
Object	TIME.down(Message msg)
Object	TP.down(Message msg)	A message needs to be sent to a single member or all members
Object	TRACE.down(Message msg)
Object	UNICAST3.down(Message msg)
Object	VERSION.down(Message msg)
CompletableFuture<Object>	VERSION.down(Message msg, boolean async)
protected void	VERSION.drop(int other_version, Message msg)
protected boolean	ASYM_ENCRYPT.dropMulticastMessageFromNonMember(Message msg)
protected void	DROP.dropped(Message m, boolean down)
protected static void	SNIFF.dump(String type, Message msg)
protected Message	Encrypt.encrypt(Message msg)
protected void	SEQUENCER.forward(Message msg, long seqno, boolean flush)
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 void	FRAG4.fragment(Message msg)
protected static GMS.GmsHeader	AUTH.getGMSHeader(Message msg)
protected byte[]	ASYM_ENCRYPT.getIv(Message msg)
protected static JoinRsp	AUTH.getJoinResponse(Message msg)
protected Object	Discovery.handle(PingHeader hdr, Message msg)
protected Object	MERGE3.handle(MERGE3.MergeHeader hdr, Message msg)
protected boolean	AUTH.handleAuthHeader(GMS.GmsHeader gms_hdr, AuthHeader auth_hdr, Message msg)	Handles a GMS header
protected void	ReliableUnicast.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.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	ReliableUnicast.handleDataReceivedFromSelf(Address sender, long seqno, Message msg)	Called when the sender of a message is the local member.
protected void	UNICAST3.handleDataReceivedFromSelf(Address sender, long seqno, Message msg)	Called when the sender of a message is the local member.
protected abstract Object	FlowControl.handleDownMessage(Message msg, int length)
protected Object	MFC.handleDownMessage(Message msg, int length)
protected Object	UFC.handleDownMessage(Message msg, int length)
protected Object	Encrypt.handleEncryptedMessage(Message msg)
protected void	ReliableMulticast.handleMessage(Message msg, NakAckHeader hdr)	Finds the corresponding retransmit buffer and adds the message to it (according to seqno).
protected void	FlowControl.handleUpEvent(Message msg, FcHeader hdr)
protected void	ReliableUnicast.handleUpEvent(Address sender, Message msg, UnicastHeader hdr)
protected void	UNICAST3.handleUpEvent(Address sender, Message msg, UnicastHeader3 hdr)
protected void	ReliableMulticast.handleXmitRsp(Message msg, NakAckHeader hdr)
protected void	BaseBundler.loopback(Address dest, Address sender, Message[] list, int len)
protected void	BaseBundler.loopbackUnlessDontLoopbackIsSet(Message msg)
static ByteArray	FD_SOCK2.messageToBuffer(Message msg)
protected static ByteArray	COMPRESS.messageToByteArray(Message msg)
protected Message	ReliableMulticast.msgFromXmitRsp(Message msg, NakAckHeader hdr)
protected boolean	AUTH.needsAuthentication(Message msg, GMS.GmsHeader hdr)
void	TP.passMessageUp(Message msg, boolean perform_cluster_name_matching, boolean multicast, boolean discard_own_mcast)
protected void	UNBATCH_OOB.passUp(Message msg)
protected static void	SNIFF.printPayload(Message msg, StringBuilder sb)
protected boolean	ASYM_ENCRYPT.processEncryptMessage(Message msg, EncryptHeader hdr, boolean retval)
protected void	MAKE_BATCH.queue(Message msg)
protected void	ReliableMulticast.queueMessage(Message msg, long seqno)
MsgStats	MsgStats.received(Message msg)
protected void	STATS.received(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	ReliableMulticast.resend(Message msg)
protected void	ReliableUnicast.resend(Message msg)
protected void	UNICAST3.resend(Message msg)
protected void	ReliableUnicast.retransmit(Message msg)	Called by the sender to resend messages for which no ACK has been received yet
protected void	UNICAST3.retransmit(Message msg)	Called by the sender to resend messages for which no ACK has been received yet
void	BaseBundler.send(Message msg)
void	Bundler.send(Message msg)
void	NoBundler.send(Message msg)
void	PerDestinationBundler.send(Message msg)
protected boolean	PerDestinationBundler.SendBuffer.send(Message msg)
protected boolean	ReliableMulticast.send(Message msg, Buffer<Message> win, boolean dont_loopback_set)
protected boolean	ReliableUnicast.send(Message msg, ReliableUnicast.SenderEntry entry, boolean dont_loopback_set)
void	TransferQueueBundler.send(Message msg)
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.sendSingle(Address dst, Message msg, ByteBufferOutputStream out)
protected void	BaseBundler.sendSingleMessage(Address dest, Message msg, ByteBufferOutputStream out)
protected void	ReliableMulticast.sendXmitRsp(Address dest, Message msg)	Sends a message msg to the requester.
MsgStats	MsgStats.sent(Message msg)
protected void	STATS.sent(Message msg)
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, boolean needs_deserialization)	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)
Object	ASYM_ENCRYPT.up(Message msg)
Object	AUTH.up(Message msg)	An event was received from the layer below.
Object	BARRIER.up(Message msg)
Object	BATCH2.up(Message msg)
Object	CLEAR_FLAGS.up(Message msg)
Object	COMPRESS.up(Message msg)	If there is no header, we pass the message up.
Object	COUNTER.up(Message msg)
Object	DAISYCHAIN.up(Message msg)
Object	DELAY.up(Message msg)
Object	DH_KEY_EXCHANGE.up(Message msg)
Object	DISCARD.up(Message msg)
Object	Discovery.up(Message msg)
Object	DROP.up(Message msg)
Object	DUPL.up(Message msg)
Object	Encrypt.up(Message msg)
Object	EXAMPLE.up(Message msg)
Object	FailureDetection.up(Message msg)
Object	FD_SOCK.up(Message msg)
Object	FD_SOCK2.up(Message msg)
Object	FlowControl.up(Message msg)
Object	FORK.up(Message msg)
Object	FRAG.up(Message msg)
Object	FRAG2.up(Message msg)
Object	FRAG3.up(Message msg)
Object	HDRS.up(Message msg)
Object	MAKE_BATCH.up(Message msg)
Object	MERGE3.up(Message msg)
Object	NON_BLOCKING_SENDS.up(Message msg)
Object	PERF.up(Message msg)
Object	RATE.up(Message msg)
Object	ReliableMulticast.up(Message msg)
Object	ReliableUnicast.up(Message msg)
Object	REVERSE.up(Message msg)
Object	REVERSE2.up(Message msg)
Object	RSVP.up(Message msg)
Object	SEQUENCER.up(Message msg)
Object	SEQUENCER2.up(Message msg)
Object	SERIALIZE.up(Message msg)
Object	SHUFFLE.up(Message msg)
Object	SIZE.up(Message msg)
Object	SIZE2.up(Message msg)
Object	SNIFF.up(Message msg)
Object	STATS.up(Message msg)
Object	STOMP.up(Message msg)
Object	THREAD_COUNT.up(Message msg)
Object	TIME.up(Message msg)
Object	UNICAST3.up(Message msg)
Object	VERIFY_SUSPECT.up(Message msg)
Object	VERIFY_SUSPECT2.up(Message msg)
Object	VERSION.up(Message msg)

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

Modifier and Type	Method	Description
protected static int	ReliableUnicast.accumulate(ToIntFunction<Buffer<Message>> func, Collection<? extends ReliableUnicast.Entry>... entries)
protected static int	UNICAST3.accumulate(ToIntFunction<Table<Message>> func, Collection<? extends UNICAST3.Entry>... entries)
protected SHUFFLE	SHUFFLE.add(List<Message> queue, Message msg, Lock lock, Consumer<Message> send_function)
protected SHUFFLE	SHUFFLE.add(List<Message> queue, Message msg, Lock lock, Consumer<Message> send_function)
DROP	DROP.addDownFilter(Predicate<Message> filter)
protected void	ReliableUnicast.addQueuedMessages(Address sender, ReliableUnicast.ReceiverEntry entry, Collection<Message> queued_msgs)
protected void	UNICAST3.addQueuedMessages(Address sender, UNICAST3.ReceiverEntry entry, Collection<Message> queued_msgs)
protected boolean	NAKACK4.addToSendBuffer(Buffer<Message> win, long seq, Message msg, Predicate<Message> filter)
protected boolean	NAKACK4.addToSendBuffer(Buffer<Message> win, long seq, Message msg, Predicate<Message> filter)
protected boolean	ReliableMulticast.addToSendBuffer(Buffer<Message> win, long seq, Message msg, Predicate<Message> filter)	Adds the message to the send buffer.
protected boolean	ReliableMulticast.addToSendBuffer(Buffer<Message> win, long seq, Message msg, Predicate<Message> filter)	Adds the message to the send buffer.
protected boolean	ReliableUnicast.addToSendBuffer(Buffer<Message> win, long seq, Message msg, Predicate<Message> filter)	Adds the message to the send buffer.
protected boolean	ReliableUnicast.addToSendBuffer(Buffer<Message> win, long seq, Message msg, Predicate<Message> filter)	Adds the message to the send buffer.
DROP	DROP.addUpFilter(Predicate<Message> filter)
HDRS	HDRS.filter(Predicate<Message> f)
REVERSE	REVERSE.filter(Predicate<Message> f)
REVERSE2	REVERSE2.filter(Predicate<Message> f)
protected void	BARRIER.flushQueue(Map<Address,Message> queue)
protected static Tuple<Long,Boolean>	ReliableUnicast.getLowestSeqno(short prot_id, List<LongTuple<Message>> list)
protected void	ReliableUnicast.handleBatchReceived(ReliableUnicast.ReceiverEntry entry, Address sender, List<LongTuple<Message>> msgs, boolean oob, Address original_dest)
protected void	UNICAST3.handleBatchReceived(UNICAST3.ReceiverEntry entry, Address sender, List<LongTuple<Message>> msgs, boolean oob, Address original_dest)
protected void	BaseBundler.loopback(Address dest, Address sender, Iterable<Message> list, int size)
protected String	ReliableUnicast.printMessageList(List<LongTuple<Message>> list)
protected String	UNICAST3.printMessageList(List<LongTuple<Message>> list)
protected void	ReliableMulticast.removeAndDeliver(Buffer<Message> win, ReliableMulticast.Entry e, Address sender, boolean loopback, AsciiString cluster)	Efficient way of checking whether another thread is already processing messages from sender.
protected void	SEQUENCER2.removeAndDeliver(Table<Message> win, Address sender)
protected void	UNICAST3.removeAndDeliver(Table<Message> win, Address sender, AsciiString cluster, int min_size)	Try to remove as many messages as possible from the table as pass them up.
DROP	DROP.removeDownFilter(Predicate<Message> filter)
DROP	DROP.removeUpFilter(Predicate<Message> filter)
protected SHUFFLE	SHUFFLE.reorderAndSend(List<Message> list, Lock lock, Consumer<Message> send_function)
protected SHUFFLE	SHUFFLE.reorderAndSend(List<Message> list, Lock lock, Consumer<Message> send_function)
protected boolean	ReliableMulticast.send(Message msg, Buffer<Message> win, boolean dont_loopback_set)
protected void	NAKACK4.sendAck(Address to, Buffer<Message> win)
protected void	ReliableMulticast.sendAck(Address to, Buffer<Message> win)
protected void	BaseBundler.sendMessageList(Address dest, Address src, List<Message> list, ByteBufferOutputStream out)
protected void	PerDestinationBundler.SendBuffer.sendMessages(Address dest, Address src, List<Message> list)
protected void	BaseBundler.sendMultiple(Address dst, Address sender, List<Message> list, ByteBufferOutputStream out)
protected static long	ReliableMulticast.sizeOfAllMessages(Buffer<Message> win, boolean include_headers)

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

Modifier	Constructor	Description
protected	Entry(Buffer<Message> buf)
protected	Entry(short conn_id, Buffer<Message> buf)
protected	Entry(short conn_id, Table<Message> msgs)
	ReceiverEntry(Buffer<Message> received_msgs, short recv_conn_id, Address real_dest)
	ReceiverEntry(Table<Message> received_msgs, short recv_conn_id, Address real_dest)

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 final Message	NAKACK2.DUMMY_OOB_MSG

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

Modifier and Type	Field	Description
protected static final BiConsumer<MessageBatch, Message>	NAKACK2.BATCH_ACCUMULATOR
protected Queue<Message>	NAKACK2.become_server_queue
protected static final Predicate<Message>	NAKACK2.dont_loopback_filter
protected final Predicate<Message>	NAKACK2.HAS_HEADER
protected Table<Message>	NAKACK2.local_xmit_table
protected final Predicate<Message>	NAKACK2.no_dummy_and_no_oob_delivered_msgs_and_no_dont_loopback_msgs
protected final Function<Message,Long>	NAKACK2.SEQNO_GETTER
protected final 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, String error_msg)
Object	NAKACK2.down(Message msg)
Object	STABLE.down(Message msg)
protected Object	GMS.handle(GMS.GmsHeader hdr, Message msg)
protected Object	StreamingStateTransfer.handle(StreamingStateTransfer.StateHeader hdr, 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.resend(Message msg)
protected void	NAKACK2.send(Message msg)	Adds the message to the sent_msgs table and then passes it down the stack.
protected void	GMS.sendViewChangeAndJoinResponse(Message view_change_msg, JoinRsp jr, Collection<Address> joiners)
protected void	NAKACK2.sendXmitRsp(Address dest, Message msg)	Sends a message msg to the requester.
Object	GMS.up(Message msg)
Object	NAKACK2.up(Message msg)
Object	STABLE.up(Message msg)
Object	STATE_TRANSFER.up(Message msg)
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.removeAndDeliver(Table<Message> buf, Address sender, boolean loopback, AsciiString cluster, int min_size)	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	RELAY.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, Collection<String> visited_sites)

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

Modifier and Type	Method	Description
protected Message	RELAY.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, Collection<String> visited_sites)
protected void	RELAY2.deliver(Address dest, Address sender, Message msg)
protected Object	RELAY3.deliver(Address next_dest, Message msg, boolean dont_relay)	Sends the message to a local destination.
protected Object	RELAY3.deliver(Address next_dest, Message msg, boolean dont_relay, boolean dont_loopback, boolean oob)
protected void	RELAY2.deliverLocally(SiteAddress dest, SiteAddress sender, Message msg)
Object	RELAY2.down(Message msg)
Object	RELAY3.down(Message msg)
protected void	RELAY2.forwardTo(Address next_dest, SiteAddress final_dest, Address original_sender, Message msg, boolean forward_to_current_coord)
protected boolean	RELAY3.handleAdminMessage(RelayHeader hdr, Message msg)	Handles SITES_UP/SITES_DOWN/TOPO_REQ/TOPO_RSP messages
protected void	RELAY2.handleMessage(RelayHeader hdr, Message msg)	Called to handle a message received by the transport
protected abstract void	RELAY.handleRelayMessage(Message msg)
protected void	RELAY2.handleRelayMessage(Message msg)	Called to handle a message received by the relayer
protected void	RELAY3.handleRelayMessage(Message msg)	Called to handle a message received from a different site (via a bridge channel)
protected boolean	RELAY3.mustBeRouted(Message msg)	Determines if a message should be routed.
protected Object	RELAY3.passUp(Message msg)	Sends a message up the stack.
protected Object	RELAY3.process(boolean down, Message msg)	This method has all the routing logic, for both site masters and regular members
void	Bridge.receive(Message msg)
void	Relayer2.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)
protected Object	RELAY3.route(Message msg, Collection<String> sites)	Sends a message to the given sites, or all sites (excluding the local site)
protected Object	RELAY3.routeThen(Message msg, List<String> sites, Supplier<Object> action)
void	Route.send(Address final_destination, Address original_sender, Message msg)
void	Route.send(Address final_destination, Address original_sender, Message msg, Collection<String> visited_sites)
protected void	RELAY2.sendToBridges(Address sender, Message msg, String... excluded_sites)	Sends the message via all bridges excluding the excluded_sites bridges
protected Object	RELAY3.sendToLocalSiteMaster(Address sender, Message msg)
Object	RELAY2.up(Message msg)
Object	RELAY3.up(Message msg)

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 final BiConsumer<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.
Object	Protocol.down(Message msg)	A message is sent down the stack.
CompletableFuture<Object>	Protocol.down(Message msg, boolean async)	Passes a message down asynchronously.
Object	ProtocolStack.down(Message msg)
CompletableFuture<Object>	ProtocolStack.down(Message msg, boolean async)
boolean	MessageProcessingPolicy.loopback(Message msg, boolean oob)	Process a message that was not received from the transport but from above (e.g.
boolean	MessageProcessingPolicy.process(Message msg, boolean oob)	Process a message received from the transport
Object	Protocol.up(Message msg)	A single message was received.
Object	ProtocolStack.up(Message msg)

Uses of Message in org.jgroups.util

Classes in org.jgroups.util that implement interfaces with type arguments of type Message

Modifier and Type	Class	Description
class	MessageBatch	Represents a message batch; multiple messages from the same sender to the same receiver(s).

Fields in org.jgroups.util declared as Message

Modifier and Type	Field	Description
protected final Message	SubmitToThreadPool.SingleMessageHandler.msg

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

Modifier and Type	Field	Description
protected static final Function<Address, Queue<Message>>	MessageCache.FUNC
protected final Map<Address, Queue<Message>>	MessageCache.map
protected FastArray<Message>	MessageBatch.messages	The storage of the messages; removed messages have a null element
protected final BlockingQueue<Message>	MaxOneThreadPerSender.Entry.mq

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

Modifier and Type	Method	Description
<T extends Message> T	MessageBatch.first()
<T extends Message> T	MessageBatch.last()

Methods in org.jgroups.util that return Message

Modifier and Type	Method	Description
static Message	Util.copy(Message msg, boolean copy_buffer, short starting_id, short... copy_only_ids)	Copies a message.
Message	SubmitToThreadPool.SingleMessageHandler.getMessage()
static Message	Util.messageFromBuffer(byte[] buf, int offset, int length)
static Message	Util.readMessage(DataInput in)

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

Modifier and Type	Method	Description
FastArray<Message>	MessageBatch.array()	Returns the underlying message array.
Collection<Message>	MessageCache.drain(Address sender)
Iterator<Message>	MessageBatch.iterator()	Iterator which iterates only over non-null messages, skipping null messages
Iterator<Message>	MessageBatch.iterator(Predicate<Message> filter)	Iterates over all non-null message which match filter
static List<Message>	Util.readMessageList(DataInput in, short transport_id)
Stream<Message>	MessageBatch.stream()
Stream<Message>	MessageBatch.stream(Predicate<Message> p)
Stream<Message>	MessageBatch.stream(Predicate<Message> p, boolean parallel)

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

Modifier and Type	Method	Description
MessageBatch	MessageBatch.add(Message msg)
MessageBatch	MessageBatch.add(Message[] msgs, int num_msgs)	Adds message to this batch from a message array
MessageBatch	MessageBatch.add(Message msg, boolean resize)	Adds a message to the table
MessageBatch	MessageBatch.add(Message msg, boolean resize, boolean determine_mode)	Adds a message to the table
MessageCache	MessageCache.add(Address sender, Message msg)
void	BundlerHelper.computeTime(String key, Message msg)
void	BundlerHelper.computeTime(String key, Message[] list)
static Message	Util.copy(Message msg, boolean copy_buffer, short starting_id, short... copy_only_ids)	Copies a message.
boolean	CreditMap.decrement(Message msg, int credits, long timeout)	Decrements credits bytes from all.
boolean	Credit.decrementIfEnoughCredits(Message msg, int credits, long timeout)
Object	MockTransport.down(Message msg)
void	ProtPerfHelper.downTime(String cluster, Message msg, String name)
void	ProtPerfHelper.downTime(Message msg, Protocol prot)
static String	Util.getObject(Message msg)	Tries to return a legible representation of a message's payload
protected static ProtPerfHeader	ProtPerfHelper.getOrAddHeader(Message msg)
void	RTT.handleMessage(Message msg, TpHeader hdr)	Called when a message (request or response) is received
boolean	MaxOneThreadPerSender.loopback(Message msg, boolean oob)
boolean	PassAllMessagesUpDirectly.loopback(Message msg, boolean oob)
boolean	PassRegularMessagesUpDirectly.loopback(Message msg, boolean oob)
boolean	SubmitToThreadPool.loopback(Message msg, boolean oob)
static ByteArray	Util.messageToBuffer(Message msg)
protected boolean	MaxOneThreadPerSender.Entry.process(Message msg)
protected boolean	MaxOneThreadPerSender.MessageTable.process(Message msg)
boolean	MaxOneThreadPerSender.process(Message msg, boolean oob)
boolean	PassAllMessagesUpDirectly.process(Message msg, boolean oob)
boolean	PassRegularMessagesUpDirectly.process(Message msg, boolean oob)
boolean	SubmitToThreadPool.process(Message msg, boolean oob)
void	MyReceiver.receive(Message msg)
MessageBatch	MessageBatch.set(Address dest, Address sender, Message[] msgs)
void	BundlerHelper.setStartTime(Message msg)
void	ProtPerfHelper.setTime(Message msg, boolean down)
void	ProtPerfHelper.setTime(Message msg, long time, boolean down)
void	ProtPerfHelper.upTime(Message msg, Protocol prot)
static void	Util.writeMessage(Message msg, DataOutput dos, boolean multicast)
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, Message[] msgs, int offset, int length, DataOutput dos, boolean multicast)

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

Modifier and Type	Method	Description
MessageBatch	MessageBatch.add(Collection<Message> msgs)
boolean	MessageBatch.anyMatch(Predicate<Message> pred)
void	BundlerHelper.computeTime(String key, List<Message> list)
void	ProtPerfHelper.downTime(String cluster, List<Message> list, String name)
static String	Util.getObjects(Iterable<Message> it)
Iterator<Message>	MessageBatch.iterator(Predicate<Message> filter)	Iterates over all non-null message which match filter
static void	Util.parse(byte[] buf, int offset, int length, BiConsumer<Short,Message> msg_consumer, BiConsumer<Short, MessageBatch> batch_consumer, Consumer<GossipData> gossip_consumer, boolean tcp, boolean gossip)
static void	Util.parse(InputStream input, BiConsumer<Short,Message> msg_consumer, BiConsumer<Short, MessageBatch> batch_consumer, Consumer<GossipData> gossip_consumer, boolean tcp, boolean gossip)
protected static void	Util.parseFrame(byte[] frame, boolean gossip, BiConsumer<Short,Message> msg_consumer, BiConsumer<Short, MessageBatch> batch_consumer, Consumer<GossipData> gossip_consumer)
MessageBatch	MessageBatch.removeIf(Predicate<Message> filter, boolean match_all)
Stream<Message>	MessageBatch.stream(Predicate<Message> p)
Stream<Message>	MessageBatch.stream(Predicate<Message> p, boolean parallel)
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, List<Message> msgs, DataOutput dos, boolean multicast)	Write a list of messages with the *same* destination and src addresses.
static void	Util.writeMessageList(Address dest, Address src, byte[] cluster_name, FastArray<Message> msgs, DataOutput dos, boolean multicast)

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

Modifier	Constructor	Description
protected	SingleMessageHandler(Message msg, boolean loopback)

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

Modifier	Constructor	Description
	MessageBatch(Collection<Message> msgs)
	MessageBatch(Address dest, Address sender, AsciiString cluster_name, boolean multicast, Collection<Message> msgs)