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>
TMessageReader. readMessage(String name)Reads nested message.Methods in org.apache.ignite.plugin.extensions.communication that return Message Modifier and Type Method Description MessageMessageFactory. 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 booleanMessageWriter. 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 booleanMessageReader. afterMessageRead(Class<? extends Message> msgCls)Callback that must be invoked by a message implementation after message body finished decoding.voidMessageFactory. register(short directType, Supplier<Message> supplier)Register message factory with given direct type.voidMessageReader. setCurrentReadClass(Class<? extends Message> msgCls)Sets type of message currently read.voidMessageWriter. 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 classJobStealingRequestJob 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 voidTcpCommunicationSpi. notifyListener(UUID sndId, Message msg, IgniteRunnable msgC)voidTcpCommunicationMetricsListener. onMessageReceived(Message msg, Object consistentId)Collects statistics for message received by SPI.voidTcpCommunicationMetricsListener. onMessageSent(Message msg, Object consistentId)Collects statistics for message sent by SPI.org.apache.ignite.internal.IgniteInternalFuture<Channel>TcpCommunicationSpi. openChannel(ClusterNode remote, Message initMsg)voidTcpCommunicationSpi. sendMessage(ClusterNode node, Message msg)Sends given message to destination node.voidTcpCommunicationSpi. 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 voidTcpCommunicationSpi. 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 classHandshakeMessageHandshake message.classHandshakeMessage2Updated handshake message.classHandshakeWaitMessageMessage requesting to wait until node's SPI context initialize.classNodeIdMessageNode ID message.classRecoveryLastReceivedMessageRecovery acknowledgment message.
-