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 and 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 and Description
default @Nullable Message	MessageFactoryProvider.create(short type) Always throws UnsupportedOperationException.
@Nullable Message	MessageFactory.create(short type) Deprecated. Creates new message instance of provided type.

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

Modifier and Type	Method and 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 and Description
boolean	MessageReader.afterMessageRead(Class<? extends Message> msgCls) Callback that must be invoked by a message implementation after message body finished decoding.
void	IgniteMessageFactory.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 and 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 and 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 and 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 and 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.