@IgniteSpiMultipleInstancesSupport(value=true) @IgniteSpiConsistencyChecked(optional=false) public class TcpCommunicationSpi extends IgniteSpiAdapter implements CommunicationSpi<Message>, TcpCommunicationSpiMBean
To enable communication with other nodes, this SPI adds ATTR_ADDRS
and ATTR_PORT
local node attributes (see ClusterNode.attributes()
.
At startup, this SPI tries to start listening to local port specified by
setLocalPort(int)
method. If local port is occupied, then SPI will
automatically increment the port number until it can successfully bind for
listening. setLocalPortRange(int)
configuration parameter controls
maximum number of ports that SPI will try before it fails. Port range comes
very handy when starting multiple grid nodes on the same machine or even
in the same VM. In this case all nodes can be brought up without a single
change in configuration.
This SPI caches connections to remote nodes so it does not have to reconnect every
time a message is sent. By default, idle connections are kept active for
DFLT_IDLE_CONN_TIMEOUT
period and then are closed. Use
setIdleConnectionTimeout(long)
configuration parameter to configure
you own idle connection timeout.
setLocalAddress(String)
)setLocalPort(int)
)setLocalPortRange(int)
setConnectionBufferFlushFrequency(long)
)setConnectionBufferSize(int)
)setIdleConnectionTimeout(long)
)setDirectBuffer(boolean)
)setDirectSendBuffer(boolean)
)setSelectorsCount(int)
)TCP_NODELAY
socket option for sockets (see setTcpNoDelay(boolean)
)setMessageQueueLimit(int)
)setMinimumBufferedMessageCount(int)
)setConnectTimeout(long)
)setMaxConnectTimeout(long)
)setReconnectCount(int)
)setSocketReceiveBuffer(int)
)setSocketSendBuffer(int)
)setSocketWriteTimeout(long)
)setAckSendThreshold(int)
)setUnacknowledgedMessagesBufferSize(int)
)TcpCommunicationSpi commSpi = new TcpCommunicationSpi(); // Override local port. commSpi.setLocalPort(4321); IgniteConfiguration cfg = new IgniteConfiguration(); // Override default communication SPI. cfg.setCommunicationSpi(commSpi); // Start grid. Ignition.start(cfg);
<bean id="grid.custom.cfg" class="org.apache.ignite.configuration.IgniteConfiguration" singleton="true"> ... <property name="communicationSpi"> <bean class="org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi"> <!-- Override local port. --> <property name="localPort" value="4321"/> </bean> </property> ... </bean>
For information about Spring framework visit www.springframework.org
CommunicationSpi
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 | Field and Description |
---|---|
static String |
ATTR_ADDRS
Node attribute that is mapped to node IP addresses (value is comm.tcp.addrs).
|
static String |
ATTR_EXT_ADDRS
Node attribute that is mapped to node's external addresses (value is comm.tcp.ext-addrs).
|
static String |
ATTR_HOST_NAMES
Node attribute that is mapped to node host names (value is comm.tcp.host.names).
|
static String |
ATTR_PORT
Node attribute that is mapped to node port number (value is comm.tcp.port).
|
static int |
DFLT_ACK_SND_THRESHOLD
Default received messages threshold for sending ack.
|
static long |
DFLT_CONN_BUF_FLUSH_FREQ
Default value for connection buffer flush frequency (value is 100 ms).
|
static int |
DFLT_CONN_BUF_SIZE
Default value for connection buffer size (value is 0).
|
static long |
DFLT_CONN_TIMEOUT
Default connection timeout (value is 1000ms).
|
static long |
DFLT_IDLE_CONN_TIMEOUT
Default idle connection timeout (value is 30000ms).
|
static long |
DFLT_MAX_CONN_TIMEOUT
Default Maximum connection timeout (value is 600,000ms).
|
static int |
DFLT_MSG_QUEUE_LIMIT
Default message queue limit per connection (for incoming and outgoing .
|
static int |
DFLT_PORT
Default port which node sets listener to (value is 47100).
|
static int |
DFLT_PORT_RANGE
Default local port range (value is 100).
|
static int |
DFLT_RECONNECT_CNT
Default reconnect attempts count (value is 10).
|
static int |
DFLT_SELECTORS_CNT
Default count of selectors for TCP server equals to
"Math.min(4, Runtime.getRuntime().availableProcessors())" . |
static int |
DFLT_SOCK_BUF_SIZE
Default socket send and receive buffer size.
|
static long |
DFLT_SOCK_WRITE_TIMEOUT
Default socket write timeout.
|
static boolean |
DFLT_TCP_NODELAY
Default value for
TCP_NODELAY socket option (value is true). |
static byte |
HANDSHAKE_MSG_TYPE |
static byte |
NODE_ID_MSG_TYPE
Node ID message type.
|
static byte |
RECOVERY_LAST_ID_MSG_TYPE |
gridName, ignite, nodeId
Constructor and Description |
---|
TcpCommunicationSpi() |
Modifier and Type | Method and Description |
---|---|
protected void |
checkConfigurationConsistency0(IgniteSpiContext spiCtx,
ClusterNode node,
boolean starting)
Method which is called in the end of checkConfigurationConsistency() method.
|
protected org.apache.ignite.internal.util.nio.GridCommunicationClient |
createNioClient(ClusterNode node) |
protected org.apache.ignite.internal.util.nio.GridCommunicationClient |
createTcpClient(ClusterNode node)
Establish TCP connection to remote node and returns client.
|
int |
getAckSendThreshold()
Gets number of received messages per connection to node after which acknowledgment message is sent.
|
long |
getConnectionBufferFlushFrequency()
Gets connection buffer flush frequency.
|
int |
getConnectionBufferSize()
Gets connection buffer size.
|
long |
getConnectTimeout()
Gets connect timeout used when establishing connection
with remote nodes.
|
long |
getIdleConnectionTimeout()
Gets maximum idle connection time upon which idle connections
will be closed.
|
CommunicationListener |
getListener() |
String |
getLocalAddress()
Gets local host address for socket binding.
|
int |
getLocalPort()
Gets local port for socket binding.
|
int |
getLocalPortRange()
Gets maximum number of local ports tried if all previously
tried ports are occupied.
|
long |
getMaxConnectTimeout()
Gets maximum connect timeout.
|
int |
getMessageQueueLimit()
Gets message queue limit for incoming and outgoing messages.
|
int |
getMinimumBufferedMessageCount()
Gets the minimum number of messages for this SPI, that are buffered
prior to sending.
|
Map<String,Object> |
getNodeAttributes()
This method is called before SPI starts (before method
IgniteSpi.spiStart(String)
is called). |
int |
getOutboundMessagesQueueSize()
Gets outbound messages queue size.
|
long |
getReceivedBytesCount()
Gets received bytes count.
|
int |
getReceivedMessagesCount()
Gets received messages count.
|
int |
getReconnectCount()
Gets maximum number of reconnect attempts used when establishing connection
with remote nodes.
|
int |
getSelectorsCount()
Gets count of selectors used in TCP server.
|
long |
getSentBytesCount()
Gets sent bytes count.
|
int |
getSentMessagesCount()
Gets sent messages count.
|
int |
getSocketReceiveBuffer()
Gets receive buffer size for sockets created or accepted by this SPI.
|
int |
getSocketSendBuffer()
Gets send buffer size for sockets created or accepted by this SPI.
|
long |
getSocketWriteTimeout()
Gets socket write timeout for TCP connections.
|
IgniteSpiContext |
getSpiContext()
Gets SPI context.
|
int |
getUnacknowledgedMessagesBufferSize()
Gets maximum number of stored unacknowledged messages per connection to node.
|
protected void |
injectResources(Ignite ignite)
Injects resources.
|
boolean |
isDirectBuffer()
Gets flag that indicates whether direct or heap allocated buffer is used.
|
boolean |
isDirectSendBuffer()
Gets flag defining whether direct send buffer should be used.
|
boolean |
isTcpNoDelay()
Gets value for
TCP_NODELAY socket option. |
protected void |
notifyListener(UUID sndId,
Message msg,
IgniteRunnable msgC) |
protected void |
onContextDestroyed0()
Method to be called in the beginning of onContextDestroyed() method.
|
void |
onContextInitialized0(IgniteSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
void |
resetMetrics()
Resets metrics for this SPI instance.
|
void |
sendMessage(ClusterNode node,
Message msg)
Sends given message to destination node.
|
void |
setAckSendThreshold(int ackSndThreshold)
Sets number of received messages per connection to node after which acknowledgment message is sent.
|
void |
setAddressResolver(AddressResolver addrRslvr)
Sets address resolver.
|
void |
setConnectionBufferFlushFrequency(long connBufFlushFreq)
Sets connection buffer flush frequency.
|
void |
setConnectionBufferSize(int connBufSize)
Sets connection buffer size.
|
void |
setConnectTimeout(long connTimeout)
Sets connect timeout used when establishing connection
with remote nodes.
|
void |
setDirectBuffer(boolean directBuf)
Sets flag to allocate direct or heap buffer in SPI.
|
void |
setDirectSendBuffer(boolean directSndBuf)
Sets whether to use direct buffer for sending.
|
void |
setIdleConnectionTimeout(long idleConnTimeout)
Sets maximum idle connection timeout upon which a connection
to client will be closed.
|
void |
setListener(CommunicationListener<Message> lsnr)
Set communication listener.
|
void |
setLocalAddress(String locAddr)
Sets local host address for socket binding.
|
void |
setLocalPort(int locPort)
Sets local port for socket binding.
|
void |
setLocalPortRange(int locPortRange)
Sets local port range for local host ports (value must greater than or equal to 0).
|
void |
setMaxConnectTimeout(long maxConnTimeout)
Sets maximum connect timeout.
|
void |
setMessageQueueLimit(int msgQueueLimit)
Sets message queue limit for incoming and outgoing messages.
|
void |
setMinimumBufferedMessageCount(int minBufferedMsgCnt)
Sets the minimum number of messages for this SPI, that are buffered
prior to sending.
|
void |
setReconnectCount(int reconCnt)
Sets maximum number of reconnect attempts used when establishing connection
with remote nodes.
|
void |
setSelectorsCount(int selectorsCnt)
Sets the count of selectors te be used in TCP server.
|
void |
setSocketReceiveBuffer(int sockRcvBuf)
Sets receive buffer size for sockets created or accepted by this SPI.
|
void |
setSocketSendBuffer(int sockSndBuf)
Sets send buffer size for sockets created or accepted by this SPI.
|
void |
setSocketWriteTimeout(long sockWriteTimeout)
Sets socket write timeout for TCP connection.
|
void |
setTcpNoDelay(boolean tcpNoDelay)
Sets value for
TCP_NODELAY socket option. |
void |
setUnacknowledgedMessagesBufferSize(int unackedMsgsBufSize)
Sets maximum number of stored unacknowledged messages per connection to node.
|
void |
spiStart(String gridName)
This method is called to start SPI.
|
void |
spiStop()
This method is called to stop SPI.
|
String |
toString() |
assertParameter, configInfo, createSpiAttributeName, getConsistentAttributeNames, getExceptionRegistry, getIgniteHome, getLocalNodeId, getName, getStartTimestamp, getStartTimestampFormatted, getUpTime, getUpTimeFormatted, injectables, isNodeStopping, onContextDestroyed, onContextInitialized, registerMBean, setName, startInfo, startStopwatch, stopInfo, unregisterMBean
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getName, onContextDestroyed, onContextInitialized
getIgniteHome, getLocalNodeId, getName, getStartTimestamp, getStartTimestampFormatted, getUpTime, getUpTimeFormatted
public static final String ATTR_ADDRS
public static final String ATTR_HOST_NAMES
public static final String ATTR_PORT
public static final String ATTR_EXT_ADDRS
public static final int DFLT_PORT
public static final long DFLT_IDLE_CONN_TIMEOUT
public static final long DFLT_CONN_BUF_FLUSH_FREQ
public static final int DFLT_CONN_BUF_SIZE
public static final int DFLT_SOCK_BUF_SIZE
public static final long DFLT_CONN_TIMEOUT
public static final long DFLT_MAX_CONN_TIMEOUT
public static final int DFLT_RECONNECT_CNT
public static final int DFLT_MSG_QUEUE_LIMIT
public static final int DFLT_SELECTORS_CNT
"Math.min(4, Runtime.getRuntime().availableProcessors())"
.public static final int DFLT_PORT_RANGE
setLocalPortRange(int)
for details.public static final boolean DFLT_TCP_NODELAY
TCP_NODELAY
socket option (value is true).public static final int DFLT_ACK_SND_THRESHOLD
public static final long DFLT_SOCK_WRITE_TIMEOUT
public static final byte NODE_ID_MSG_TYPE
public static final byte RECOVERY_LAST_ID_MSG_TYPE
public static final byte HANDSHAKE_MSG_TYPE
@IgniteSpiConfiguration(optional=true) public void setAddressResolver(AddressResolver addrRslvr)
addrRslvr
- Address resolver.@IgniteInstanceResource protected void injectResources(Ignite ignite)
injectResources
in class IgniteSpiAdapter
ignite
- Ignite.@IgniteSpiConfiguration(optional=true) public void setLocalAddress(String locAddr)
locAddr
- IP address. Default value is any available local
IP address.public String getLocalAddress()
getLocalAddress
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setLocalPort(int locPort)
If not provided, default value is DFLT_PORT
.
locPort
- Port number.public int getLocalPort()
getLocalPort
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setLocalPortRange(int locPortRange)
setLocalPort(int)
} is occupied,
implementation will try to increment the port number for as long as it is less than
initial value plus this range.
If port range value is 0, then implementation will try bind only to the port provided by
setLocalPort(int)
method and fail if binding to this port did not succeed.
Local port range is very useful during development when more than one grid nodes need to run on the same physical machine.
If not provided, default value is DFLT_PORT_RANGE
.
locPortRange
- New local port range.public int getLocalPortRange()
getLocalPortRange
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setIdleConnectionTimeout(long idleConnTimeout)
If not provided, default value is DFLT_IDLE_CONN_TIMEOUT
.
idleConnTimeout
- Maximum idle connection time.public long getIdleConnectionTimeout()
getIdleConnectionTimeout
in interface TcpCommunicationSpiMBean
public long getSocketWriteTimeout()
getSocketWriteTimeout
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setSocketWriteTimeout(long sockWriteTimeout)
Default to DFLT_SOCK_WRITE_TIMEOUT
.
sockWriteTimeout
- Socket write timeout for TCP connection.public int getAckSendThreshold()
getAckSendThreshold
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setAckSendThreshold(int ackSndThreshold)
Default to DFLT_ACK_SND_THRESHOLD
.
ackSndThreshold
- Number of received messages after which acknowledgment is sent.public int getUnacknowledgedMessagesBufferSize()
getUnacknowledgedMessagesBufferSize
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setUnacknowledgedMessagesBufferSize(int unackedMsgsBufSize)
unackedMsgsBufSize
- Maximum number of unacknowledged messages.@IgniteSpiConfiguration(optional=true) public void setConnectionBufferSize(int connBufSize)
0
connection buffer is disabled.
If not provided, default value is DFLT_CONN_BUF_SIZE
.
connBufSize
- Connection buffer size.setConnectionBufferFlushFrequency(long)
public int getConnectionBufferSize()
If set to 0
connection buffer is disabled.
getConnectionBufferSize
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setConnectionBufferFlushFrequency(long connBufFlushFreq)
Client connections to other nodes in topology use buffered output. This frequency defines how often system will advice to flush connection buffer.
If not provided, default value is DFLT_CONN_BUF_FLUSH_FREQ
.
This property is used only if TcpCommunicationSpiMBean.getConnectionBufferSize()
is greater than 0
.
setConnectionBufferFlushFrequency
in interface TcpCommunicationSpiMBean
connBufFlushFreq
- Flush frequency.TcpCommunicationSpiMBean.getConnectionBufferSize()
public long getConnectionBufferFlushFrequency()
Client connections to other nodes in topology use buffered output. This frequency defines how often system will advice to flush connection buffer.
getConnectionBufferFlushFrequency
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setConnectTimeout(long connTimeout)
0
is interpreted as infinite timeout.
If not provided, default value is DFLT_CONN_TIMEOUT
.
connTimeout
- Connect timeout.public long getConnectTimeout()
getConnectTimeout
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setMaxConnectTimeout(long maxConnTimeout)
0
is interpreted as infinite timeout.
If not provided, default value is DFLT_MAX_CONN_TIMEOUT
.
maxConnTimeout
- Maximum connect timeout.public long getMaxConnectTimeout()
getMaxConnectTimeout
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setReconnectCount(int reconCnt)
If not provided, default value is DFLT_RECONNECT_CNT
.
reconCnt
- Maximum number of reconnection attempts.public int getReconnectCount()
getReconnectCount
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setDirectBuffer(boolean directBuf)
true
, then SPI will use ByteBuffer.allocateDirect(int)
call.
Otherwise, SPI will use ByteBuffer.allocate(int)
call.
If not provided, default value is true
.
directBuf
- Flag indicates to allocate direct or heap buffer in SPI.public boolean isDirectBuffer()
isDirectBuffer
in interface TcpCommunicationSpiMBean
public boolean isDirectSendBuffer()
isDirectSendBuffer
in interface TcpCommunicationSpiMBean
True
if direct buffers should be used.@IgniteSpiConfiguration(optional=true) public void setDirectSendBuffer(boolean directSndBuf)
If not provided default is false
.
directSndBuf
- True
to use direct buffers for send.@IgniteSpiConfiguration(optional=true) public void setSelectorsCount(int selectorsCnt)
DFLT_SELECTORS_CNT
.selectorsCnt
- Selectors count.public int getSelectorsCount()
getSelectorsCount
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setTcpNoDelay(boolean tcpNoDelay)
TCP_NODELAY
socket option. Each
socket will be opened using provided value.
Setting this option to true
disables Nagle's algorithm
for socket decreasing latency and delivery time for small messages.
For systems that work under heavy network load it is advisable to
set this value to false
.
If not provided, default value is DFLT_TCP_NODELAY
.
tcpNoDelay
- True
to disable TCP delay.public boolean isTcpNoDelay()
TCP_NODELAY
socket option.isTcpNoDelay
in interface TcpCommunicationSpiMBean
True
if TCP delay is disabled.@IgniteSpiConfiguration(optional=true) public void setSocketReceiveBuffer(int sockRcvBuf)
If not provided, default is DFLT_SOCK_BUF_SIZE
.
sockRcvBuf
- Socket receive buffer size.public int getSocketReceiveBuffer()
If not provided, default is DFLT_SOCK_BUF_SIZE
.
getSocketReceiveBuffer
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setSocketSendBuffer(int sockSndBuf)
If not provided, default is DFLT_SOCK_BUF_SIZE
.
sockSndBuf
- Socket send buffer size.public int getSocketSendBuffer()
If not provided, default is DFLT_SOCK_BUF_SIZE
.
getSocketSendBuffer
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setMessageQueueLimit(int msgQueueLimit)
When set to positive number send queue is limited to the configured value.
0
disables the size limitations.
If not provided, default is DFLT_MSG_QUEUE_LIMIT
.
msgQueueLimit
- Send queue size limit.public int getMessageQueueLimit()
getMessageQueueLimit
in interface TcpCommunicationSpiMBean
@IgniteSpiConfiguration(optional=true) public void setMinimumBufferedMessageCount(int minBufferedMsgCnt)
Defaults to either 512
or IgniteSystemProperties.IGNITE_MIN_BUFFERED_COMMUNICATION_MSG_CNT
system property (if specified).
minBufferedMsgCnt
- Minimum buffered message count.public int getMinimumBufferedMessageCount()
getMinimumBufferedMessageCount
in interface TcpCommunicationSpiMBean
public void setListener(CommunicationListener<Message> lsnr)
setListener
in interface CommunicationSpi<Message>
lsnr
- Listener to set or null
to unset the listener.public CommunicationListener getListener()
public int getSentMessagesCount()
getSentMessagesCount
in interface CommunicationSpi<Message>
getSentMessagesCount
in interface TcpCommunicationSpiMBean
public long getSentBytesCount()
getSentBytesCount
in interface CommunicationSpi<Message>
getSentBytesCount
in interface TcpCommunicationSpiMBean
public int getReceivedMessagesCount()
getReceivedMessagesCount
in interface CommunicationSpi<Message>
getReceivedMessagesCount
in interface TcpCommunicationSpiMBean
public long getReceivedBytesCount()
getReceivedBytesCount
in interface CommunicationSpi<Message>
getReceivedBytesCount
in interface TcpCommunicationSpiMBean
public int getOutboundMessagesQueueSize()
getOutboundMessagesQueueSize
in interface CommunicationSpi<Message>
getOutboundMessagesQueueSize
in interface TcpCommunicationSpiMBean
public void resetMetrics()
resetMetrics
in interface CommunicationSpi<Message>
public Map<String,Object> getNodeAttributes() throws IgniteSpiException
IgniteSpi.spiStart(String)
is called). It allows SPI implementation to add attributes to a local
node. Kernal collects these attributes from all SPI implementations
loaded up and then passes it to discovery SPI so that they can be
exchanged with other nodes.getNodeAttributes
in interface IgniteSpi
getNodeAttributes
in class IgniteSpiAdapter
IgniteSpiException
- Throws in case of any error.public void spiStart(String gridName) throws IgniteSpiException
spiStart
in interface IgniteSpi
gridName
- Name of grid instance this SPI is being started for
(null
for default grid).IgniteSpiException
- Throws in case of any error during SPI start.public void onContextInitialized0(IgniteSpiContext spiCtx) throws IgniteSpiException
onContextInitialized0
in class IgniteSpiAdapter
spiCtx
- SPI context.IgniteSpiException
- In case of errors.public IgniteSpiContext getSpiContext()
getSpiContext
in class IgniteSpiAdapter
public void spiStop() throws IgniteSpiException
Note that this method can be called at any point including during recovery of failed start. It should make no assumptions on what state SPI will be in when this method is called.
spiStop
in interface IgniteSpi
IgniteSpiException
- Thrown in case of any error during SPI stop.protected void onContextDestroyed0()
onContextDestroyed0
in class IgniteSpiAdapter
protected void checkConfigurationConsistency0(IgniteSpiContext spiCtx, ClusterNode node, boolean starting) throws IgniteSpiException
checkConfigurationConsistency0
in class IgniteSpiAdapter
spiCtx
- SPI context.node
- Remote node.starting
- If this node is starting or not.IgniteSpiException
- in case of errors.public void sendMessage(ClusterNode node, Message msg) throws IgniteSpiException
sendMessage
in interface CommunicationSpi<Message>
node
- Destination node.msg
- Message to send.IgniteSpiException
- Thrown in case of any error during sending the message.
Note that this is not guaranteed that failed communication will result
in thrown exception as this is dependant on SPI implementation.@Nullable protected org.apache.ignite.internal.util.nio.GridCommunicationClient createNioClient(ClusterNode node) throws IgniteCheckedException
node
- Node to create client for.IgniteCheckedException
- If failed.protected org.apache.ignite.internal.util.nio.GridCommunicationClient createTcpClient(ClusterNode node) throws IgniteCheckedException
node
- Remote node.IgniteCheckedException
- If failed.protected void notifyListener(UUID sndId, Message msg, IgniteRunnable msgC)
sndId
- Sender ID.msg
- Communication message.msgC
- Closure to call when message processing finished.
Follow @ApacheIgnite
Ignite Fabric : ver. 1.1.0-incubating Release Date : May 20 2015