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.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.tests
org.jgroups.tests.perf
org.jgroups.tests.rt.transports
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.
class	ObjectMessage	A Message with an object as payload.

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 Map<Short,Supplier<? extends Message>>	DefaultMessageFactory.map

Methods in org.jgroups with type parameters of type Message

Modifier and Type	Method	Description
<T extends Message> T	DefaultMessageFactory.create(short type)
<T extends Message> T	MessageFactory.create(short id)	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).
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.
Message	Message.setArray(ByteArray buf)	Sets the byte array in a message.
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
<T extends MessageFactory> T	DefaultMessageFactory.register(short type, Supplier<? extends Message> generator)
<M extends MessageFactory> M	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)

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	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 Message[]	RingBufferBundlerLockless.buf
protected Message[]	RingBufferBundlerLockless2.buf
protected static final Message	UNICAST3.DUMMY_OOB_MSG
protected final Message[]	FRAG2.FragEntry.fragments
private final Message	DELAY.DelayedMessage.msg
protected Message	FRAG3.FragEntry.msg
protected final Message[]	SimplifiedTransferQueueBundler.msg_queue
private Message[]	BATCH.Buffer.msgs
private Message[]	BATCH2.Buffer.msgs
private final Message[]	BatchBundler.Buffer.msgs
static final 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 final BiConsumer<MessageBatch,Message>	SEQUENCER2.BATCH_ACCUMULATOR
protected static final BiConsumer<MessageBatch,Message>	UNICAST3.BATCH_ACCUMULATOR
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>	UNICAST3.drop_oob_and_dont_loopback_msgs_filter
protected Predicate<Message>	HDRS.filter
protected Predicate<Message>	REVERSE.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 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 Map<Address,Message>	BARRIER.mcast_queue
protected final Map<Address,List<Message>>	BaseBundler.msgs	Keys are destinations, values are lists of Messages
protected final FastArray<Message>	PerDestinationBundler.SendBuffer.msgs
protected final Table<Message>	UNICAST3.Entry.msgs
protected final Map<Address,List<Message>>	MAKE_BATCH.oob_map_mcast
protected final Map<Address,List<Message>>	MAKE_BATCH.oob_map_ucast
private final BlockingQueue<Message>	PerDestinationBundler.SendBuffer.queue
protected final Deque<Message>	REVERSE.queue
protected BlockingQueue<Message>	TransferQueueBundler.queue
protected BlockingQueue<Message>	TransferQueueBundler2.queue
protected RingBuffer<Message>	RemoveQueueBundler.rb
protected RingBuffer<Message>	RingBufferBundler.rb
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 final List<Message>	BATCH2.remove_queue
private final List<Message>	PerDestinationBundler.SendBuffer.remove_queue
protected final List<Message>	TransferQueueBundler.remove_queue
protected List<Message>	TransferQueueBundler2.remove_queue
protected final Consumer<Message>	MFC_NB.send_function
protected final Consumer<Message>	UFC_NB.send_function
protected final List<Message>	AlternatingBundler.target_list
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 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, MessageFactory msg_factory)
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
private Message	FRAG.unfragment(Message msg, FragHeader hdr)	1.
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()
protected Table<Message>	UNICAST3.createTable(long seqno)
Predicate<Message>	REVERSE.filter()
Table<Message>	UNICAST3.getSendWindow(Address target)	Used for testing only!

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 Object	SimpleTCP._down(Message msg)
protected void	BatchBundler._send(Message msg, ByteArrayDataOutputStream out)
protected void	TP._send(Message msg, Address dest)
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 void	TransferQueueBundler2.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	AlternatingBundler.addMessage(Message msg, int size)
protected void	BaseBundler.addMessage(Message msg, int size)
protected boolean	BATCH.Buffer.addMessage(Message msg)
protected boolean	BATCH2.Buffer.addMessage(Message msg)
protected boolean	BatchBundler.Buffer.addMessage(Message msg)
protected void	PerDestinationBundler.SendBuffer.addMessage(Message msg, int size)
protected void	SimplifiedTransferQueueBundler.addMessage(Message msg, int size)
private TransferQueueBundler2.Buffer	TransferQueueBundler2.Buffer.addMessage(Message msg, TP transport)
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 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)
private void	DUPL.copy(Message msg, int num_copies, DUPL.Direction direction)
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	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)
Object	ASYM_ENCRYPT.down(Message msg)
Object	AUTH.down(Message msg)
Object	BATCH.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	DETECT_LOOPBACKS.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)
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	SimpleTCP.down(Message msg)
Object	SIZE.down(Message msg)
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)
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)
private void	FRAG.fragment(Message msg)	Send all fragments as separate messages (with same ID !).
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	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 Object	FlowControl.handleDownMessage(Message msg, int length)
protected Object	MFC_NB.handleDownMessage(Message msg, int length)
protected Object	MFC.handleDownMessage(Message msg, int length)
protected Object	UFC_NB.handleDownMessage(Message msg, int length)
protected Object	UFC.handleDownMessage(Message msg, int length)
protected Object	Encrypt.handleEncryptedMessage(Message msg)
protected void	FlowControl.handleUpEvent(Message msg, FcHeader hdr)
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)
static ByteArray	FD_SOCK2.messageToBuffer(Message msg)
protected static ByteArray	COMPRESS.messageToByteArray(Message msg)
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 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)
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	UNICAST3.resend(Message msg)
protected void	UNICAST3.retransmit(Message msg)	Called by the sender to resend messages for which no ACK has been received yet
void	AsyncNoBundler.send(Message msg)
void	BaseBundler.send(Message msg)
void	BatchBundler.send(Message msg)
void	Bundler.send(Message msg)
void	NoBundler.send(Message msg)
void	PerDestinationBundler.send(Message msg)
protected void	PerDestinationBundler.SendBuffer.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)
void	TransferQueueBundler.send(Message msg)
void	TransferQueueBundler2.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	BatchBundler.Buffer.sendMessageList(Address dest, Address src, Message[] list, int length)
protected void	BaseBundler.sendSingleMessage(Message msg)
protected void	NoBundler.sendSingleMessage(Message msg, ByteArrayDataOutputStream output)
protected void	PerDestinationBundler.SendBuffer.sendSingleMessage(Address dest, Message msg)
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
private Message	FRAG.unfragment(Message msg, FragHeader hdr)	1.
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	BATCH.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	Locking.up(Message msg)	Deprecated.
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	REVERSE.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	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)

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

Modifier and Type	Method	Description
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)
protected SHUFFLE	SHUFFLE.add(List<Message> queue, MessageBatch batch, Lock lock, Consumer<Message> send_function)
protected SHUFFLE	SHUFFLE.add(List<Message> queue, MessageBatch batch, Lock lock, Consumer<Message> send_function)
DROP	DROP.addDownFilter(Predicate<Message> filter)
protected void	UNICAST3.addQueuedMessages(Address sender, UNICAST3.ReceiverEntry entry, Collection<Message> queued_msgs)
DROP	DROP.addUpFilter(Predicate<Message> filter)
HDRS	HDRS.filter(Predicate<Message> f)
REVERSE	REVERSE.filter(Predicate<Message> f)
protected void	BARRIER.flushQueue(Map<Address,Message> queue)
protected void	UNICAST3.handleBatchReceived(UNICAST3.ReceiverEntry entry, Address sender, List<LongTuple<Message>> msgs, boolean oob, Address original_dest)
protected String	UNICAST3.printMessageList(List<LongTuple<Message>> list)
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(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 void	PerDestinationBundler.SendBuffer.sendBatch(Address destination, FastArray<Message> list)
protected void	BaseBundler.sendMessageList(Address dest, Address src, List<Message> list)
protected void	PerDestinationBundler.SendBuffer.sendMessageList(Address dest, Address src, FastArray<Message> list)
protected void	RemoveQueueBundler.sendMessageList(Address dest, Address src, List<Message> list)
protected void	PerDestinationBundler.SendBuffer.sendMessages(Address dest, Address src, FastArray<Message> list)

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

Modifier	Constructor	Description
	DelayedMessage(Message msg, long start)

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

Modifier	Constructor	Description
protected	Entry(short conn_id, Table<Message> msgs)
	ReceiverEntry(Table<Message> received_msgs, short recv_conn_id, Address real_dest)
protected	RingBufferBundler(RingBuffer<Message> rb)
protected	TransferQueueBundler2(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 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	FLUSH.down(Message msg)	Deprecated, for removal: This API element is subject to removal in a future version.
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)
private void	FLUSH.handleFlushReconcile(Message msg)	Deprecated, for removal: This API element is subject to removal in a future version.
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)
private void	FLUSH.handleStartFlush(Message msg, FLUSH.FlushHeader fh)	Deprecated, for removal: This API element is subject to removal in a future version.
protected void	NAKACK2.handleXmitRsp(Message msg, NakAckHeader2 hdr)
protected Message	NAKACK2.msgFromXmitRsp(Message msg, NakAckHeader2 hdr)
private void	FLUSH.onFlushCompleted(Address address, Message m, FLUSH.FlushHeader header)	Deprecated, for removal: This API element is subject to removal in a future version.
private void	FLUSH.onFlushReconcileOK(Message msg)	Deprecated, for removal: This API element is subject to removal in a future version.
private void	FLUSH.onStartFlush(Address flushStarter, Message msg, FLUSH.FlushHeader fh)	Deprecated, for removal: This API element is subject to removal in a future version.
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	NAKACK2.sendXmitRsp(Address dest, Message msg)	Sends a message msg to the requester.
Object	FLUSH.up(Message msg)	Deprecated, for removal: This API element is subject to removal in a future version.
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_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	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.tests

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

Modifier and Type	Field	Description
(package private) final BiConsumer<Short,Message>	ParseMessages.InnerParseMessages.msg_consumer

Methods in org.jgroups.tests that return Message

Modifier and Type	Method	Description
protected static final Message	UnicastTestTcp.readMessage(DataInput in)
protected static Message	UnicastTestTcpSlow.readMessage(byte[] buf, int offset, int length)

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

Modifier and Type	Method	Description
protected static View	ParseMessages.getView(Message msg)
Object	MessageDispatcherSpeedTest.handle(Message msg)
protected static void	ParseMessages.parseDiscoveryResponse(Message msg)
void	FlowControlTest.receive(Message msg)
void	LargeState.receive(Message msg)
void	MessageSendTest.receive(Message msg)
void	PingPong.receive(Message msg)
void	UnicastTest.MyReceiver.receive(Message msg)
void	UnicastTestTcp.receive(Message msg)
void	UnicastTestTcpSlow.receive(Message msg)
protected void	MessageSendTest.send(Message msg)
protected static final void	UnicastTestTcp.writeMessage(Message msg, DataOutputStream out)
protected ByteArray	UnicastTestTcpSlow.Sender.writeMessage(Message msg)

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

Modifier and Type	Method	Description
void	ParseMessages.InnerParseMessages.parse(InputStream input, BiConsumer<Short,Message> msg_consumer, BiConsumer<Short,MessageBatch> batch_consumer, Consumer<GossipData> gossip_consumer, boolean tcp, boolean gossip)
static void	ParseMessages.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)
void	ParseMessages.parse(InputStream in, BiConsumer<Short,Message> msg_consumer, BiConsumer<Short,MessageBatch> batch_consumer, Consumer<GossipData> gossip_consumer, boolean tcp, boolean gossip)
void	ParseMessagesFields.parse(InputStream in, BiConsumer<Short,Message> msg_consumer, BiConsumer<Short,MessageBatch> batch_consumer, Consumer<GossipData> gossip_consumer, boolean tcp, boolean gossip)
void	ParseMessagesFields.parseWithFields(InputStream input, BiConsumer<Short,Message> msg_consumer, BiConsumer<Short,MessageBatch> batch_consumer, boolean tcp, boolean gossip)

Uses of Message in org.jgroups.tests.perf

Methods in org.jgroups.tests.perf with parameters of type Message

Modifier and Type	Method	Description
void	MPerf.receive(Message msg)

Uses of Message in org.jgroups.tests.rt.transports

Methods in org.jgroups.tests.rt.transports with parameters of type Message

Modifier and Type	Method	Description
void	JGroupsTransport.receive(Message msg)

Uses of Message in org.jgroups.util

Fields in org.jgroups.util declared as Message

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

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

Modifier and Type	Field	Description
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 SizeBoundedQueue<Message>	NonBlockingCredit.msg_queue
protected final SizeBoundedQueue<Message>	NonBlockingCreditMap.msg_queue
protected static final Consumer<Message>	NonBlockingCredit.NO_OP_SEND_FUNCTION
protected static final Consumer<Message>	NonBlockingCreditMap.NO_OP_SEND_FUNCTION
protected final Consumer<Message>	NonBlockingCredit.send_function
protected final Consumer<Message>	NonBlockingCreditMap.send_function

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, MessageFactory mf)
static Message	Util.messageFromByteBuffer(byte[] buffer, int offset, int length, MessageFactory mf)
static Message	Util.readMessage(DataInput in, MessageFactory mf)

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, MessageFactory mf)
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)
int	MessageBatch.add(Message[] msgs, int num_msgs)	Adds message to this batch from a message array
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
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	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.
static String	Util.getObject(Message msg)	Tries to return a legible representation of a message's payload
void	RTT.handleMessage(Message msg, TpHeader hdr)	Called when a message (request or response) is received
boolean	MaxOneThreadPerSender.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)
static ByteArray	Util.messageToByteBuffer(Message msg)
protected boolean	MaxOneThreadPerSender.Entry.process(Message msg, boolean loopback)
protected boolean	MaxOneThreadPerSender.MessageTable.process(Message msg, boolean loopback)
boolean	MaxOneThreadPerSender.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)
protected boolean	MaxOneThreadPerSender.Entry.submit(Message msg, boolean loopback)
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
int	MessageBatch.add(Collection<Message> msgs)
boolean	MessageBatch.anyMatch(Predicate<Message> pred)
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)
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
	SingleLoopbackHandler(Message msg)
protected	SingleMessageHandler(Message msg)
protected	SingleMessageHandlerWithClusterName(Message msg, byte[] cluster_name)

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)
	NonBlockingCredit(long credits, int max_size, Lock lock, Consumer<Message> send_function)
	NonBlockingCreditMap(long max_credits, int max_size, Lock lock, Consumer<Message> send_function)