Uses of Interface
org.apache.ignite.plugin.extensions.communication.Message

Packages that use Message

Package	Description
org.apache.ignite.plugin.extensions.communication	Contains extendable components for communication.
org.apache.ignite.spi.collision.jobstealing	Contains job stealing collision SPI implementation.
org.apache.ignite.spi.communication.tcp	Contains default TCP/IP-based implementation for communication SPI.
org.apache.ignite.spi.communication.tcp.messages	Contains implementation messages.

Uses of Message in org.apache.ignite.plugin.extensions.communication

Methods in org.apache.ignite.plugin.extensions.communication with type parameters of type Message

Modifier and Type	Method	Description
<T extends Message> T	MessageReader.readMessage(String name)	Reads nested message.

Methods in org.apache.ignite.plugin.extensions.communication that return Message

Modifier and Type	Method	Description
Message	MessageFactory.create(short type)	Creates new message instance of provided type.

Methods in org.apache.ignite.plugin.extensions.communication with parameters of type Message

Modifier and Type	Method	Description
boolean	MessageWriter.writeMessage(String name, Message val)	Writes nested message.

Method parameters in org.apache.ignite.plugin.extensions.communication with type arguments of type Message

Modifier and Type	Method	Description
boolean	MessageReader.afterMessageRead(Class<? extends Message> msgCls)	Callback that must be invoked by a message implementation after message body finished decoding.
void	MessageFactory.register(short directType, Supplier<Message> supplier)	Register message factory with given direct type.
void	MessageReader.setCurrentReadClass(Class<? extends Message> msgCls)	Sets type of message currently read.
void	MessageWriter.setCurrentWriteClass(Class<? extends Message> msgCls)	Sets type of message currently written.

Uses of Message in org.apache.ignite.spi.collision.jobstealing

Classes in org.apache.ignite.spi.collision.jobstealing that implement Message

Modifier and Type	Class	Description
class	JobStealingRequest	Job stealing request.

Uses of Message in org.apache.ignite.spi.communication.tcp

Methods in org.apache.ignite.spi.communication.tcp with parameters of type Message

Modifier and Type	Method	Description
protected void	TcpCommunicationSpi.notifyListener(UUID sndId, Message msg, IgniteRunnable msgC)
void	TcpCommunicationMetricsListener.onMessageReceived(Message msg, Object consistentId)	Collects statistics for message received by SPI.
void	TcpCommunicationMetricsListener.onMessageSent(Message msg, Object consistentId)	Collects statistics for message sent by SPI.
org.apache.ignite.internal.IgniteInternalFuture<Channel>	TcpCommunicationSpi.openChannel(ClusterNode remote, Message initMsg)
void	TcpCommunicationSpi.sendMessage(ClusterNode node, Message msg)	Sends given message to destination node.
void	TcpCommunicationSpi.sendMessage(ClusterNode node, Message msg, IgniteInClosure<IgniteException> ackC)	Sends given message to destination node.

Method parameters in org.apache.ignite.spi.communication.tcp with type arguments of type Message

Modifier and Type	Method	Description
void	TcpCommunicationSpi.setListener(CommunicationListener<Message> lsnr)	Deprecated.

Uses of Message in org.apache.ignite.spi.communication.tcp.messages

Classes in org.apache.ignite.spi.communication.tcp.messages that implement Message

Modifier and Type	Class	Description
class	HandshakeMessage	Handshake message.
class	HandshakeMessage2	Updated handshake message.
class	HandshakeWaitMessage	Message requesting to wait until node's SPI context initialize.
class	NodeIdMessage	Node ID message.
class	RecoveryLastReceivedMessage	Recovery acknowledgment message.