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.
|
Modifier and Type | Method and Description |
---|---|
<T extends Message> |
MessageReader.readMessage(String name)
Reads nested message.
|
Modifier and Type | Method and Description |
---|---|
Message |
MessageFactory.create(byte type)
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 | Class and Description |
---|---|
class |
JobStealingRequest
Job stealing request.
|
Modifier and Type | Class and Description |
---|---|
static class |
TcpCommunicationSpi.HandshakeMessage
Handshake message.
|
static class |
TcpCommunicationSpi.NodeIdMessage
Node ID message.
|
static class |
TcpCommunicationSpi.RecoveryLastReceivedMessage
Recovery acknowledgment message.
|
Modifier and Type | Method and Description |
---|---|
protected void |
TcpCommunicationSpi.notifyListener(UUID sndId,
Message msg,
IgniteRunnable msgC) |
void |
TcpCommunicationSpi.sendMessage(ClusterNode node,
Message msg)
Sends given message to destination node.
|
Modifier and Type | Method and Description |
---|---|
void |
TcpCommunicationSpi.setListener(CommunicationListener<Message> lsnr)
Set communication listener.
|
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0 Release Date : March 31 2015