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.
|
Modifier and Type | Method and Description |
---|---|
<T extends Message> |
MessageReader.readMessage(String name)
Reads nested message.
|
Modifier and Type | Method and Description |
---|---|
default @Nullable Message |
MessageFactoryProvider.create(short type)
Always throws
UnsupportedOperationException . |
Message |
MessageFactory.create(short type)
Deprecated.
Creates new message instance of provided type.
|
Modifier and Type | Method and Description |
---|---|
boolean |
MessageWriter.writeMessage(String name,
Message val)
Writes nested 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.
|
Modifier and Type | Class and Description |
---|---|
class |
JobStealingRequest
Job stealing request.
|
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.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
TcpCommunicationSpi.setListener(CommunicationListener<Message> lsnr)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
ConnectionCheckMessage
Special message to check TCP communication connection is alive.
|
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.
|
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024