org.gridgain.grid.spi.communication.tcp
Class GridTcpCommunicationSpi

java.lang.Object
  org.gridgain.grid.spi.GridSpiAdapter
      org.gridgain.grid.spi.communication.tcp.GridTcpCommunicationSpi

All Implemented Interfaces:

GridCommunicationSpi, GridTcpCommunicationSpiMBean, GridSpi, GridSpiJsonConfigurable, GridSpiManagementMBean

@GridSpiInfo(author="GridGain Project",
             url="www.gridgain.org",
             email="support@gridgain.com",
             version="3.0")
@GridSpiMultipleInstancesSupport(value=true)
public class GridTcpCommunicationSpi
extends GridSpiAdapter
implements GridCommunicationSpi, GridTcpCommunicationSpiMBean

GridTcpCommunicationSpi is default communication SPI which uses TCP/IP protocol and Java NIO to communicate with other nodes.

To enable communication with other nodes, this SPI adds GridTcpCommunicationSpi.ATTR_ADDR and GridTcpCommunicationSpi.ATTR_PORT local node attributes (see GridNode.attributes().

At startup, this SPI tries to start listening to local port specified by GridTcpCommunicationSpi.setLocalPort(int) method. If local port is occupied, then SPI will automatically increment the port number until it can successfully bind for listening. GridTcpCommunicationSpi.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 GridTcpCommunicationSpi.DFLT_IDLE_CONN_TIMEOUT period and then are closed. Use GridTcpCommunicationSpi.setIdleConnectionTimeout(long) configuration parameter to configure you own idle connection timeout. In some cases network performance may be increased if more that one active TCP connection is used. By default, SPI uses GridTcpCommunicationSpi.DFLT_MAX_OPEN_CLIENTS as maximum open clients. Use GridTcpCommunicationSpi.setMaxOpenClients(int) configuration parameter to configure maximum count of open clients per remote node.

Configuration

Mandatory

This SPI has no mandatory configuration parameters.

Optional

The following configuration parameters are optional:

• Node local IP address (see GridTcpCommunicationSpi.setLocalAddress(String))
• Node local port number (see GridTcpCommunicationSpi.setLocalPort(int))
• Local port range (see GridTcpCommunicationSpi.setLocalPortRange(int)
• Port resolver (see GridTcpCommunicationSpi.setSpiPortResolver(GridSpiPortResolver)
• Number of threads used for handling NIO messages (see GridTcpCommunicationSpi.setMessageThreads(int))
• Idle connection timeout (see GridTcpCommunicationSpi.setIdleConnectionTimeout(long))
• Direct or heap buffer allocation (see GridTcpCommunicationSpi.setDirectBuffer(boolean))
• Count of selectors and selector threads for NIO server (see GridTcpCommunicationSpi.setSelectorsCount(int))
• Maximum count of open clients per remote node (see GridTcpCommunicationSpi.setMaxOpenClients(int))

Java Example

GridTcpCommunicationSpi is used by default and should be explicitly configured only if some SPI configuration parameters need to be overridden.

 GridTcpCommunicationSpi commSpi = new GridTcpCommunicationSpi();

 // Override local port.
 commSpi.setLocalPort(4321);

 GridConfigurationAdapter cfg = new GridConfigurationAdapter();

 // Override default communication SPI.
 cfg.setCommunicationSpi(commSpi);

 // Start grid.
 GridFactory.start(cfg);
 

Spring Example

GridTcpCommunicationSpi can be configured from Spring XML configuration file:

 <bean id="grid.custom.cfg" class="org.gridgain.grid.GridConfigurationAdapter" singleton="true">
         ...
         <property name="communicationSpi">
             <bean class="org.gridgain.grid.spi.communication.tcp.GridTcpCommunicationSpi">
                 <!-- Override local port. -->
                 <property name="localPort" value="4321"/>
             </bean>
         </property>
         ...
 </bean>
 

For information about Spring framework visit www.springframework.org

Wiki & Forum:

Wiki
Forum

See Also:

GridCommunicationSpi

Field Summary

static String	ATTR_ADDR Node attribute that is mapped to node IP address (value is comm.tcp.addr).
static String	ATTR_EXT_PORTS Node attribute that is mapped to node's external ports numbers (value is comm.tcp.ext-ports).
static String	ATTR_PORT Node attribute that is mapped to node port number (value is comm.tcp.port).
static int	DFLT_CONN_TIMEOUT Default connection timeout (value is 1000ms).
static int	DFLT_IDLE_CONN_TIMEOUT Default idle connection timeout (value is 30000ms).
static int	DFLT_MAX_OPEN_CLIENTS Default maximum count of simultaneously open client for one node (value is 1).
static int	DFLT_MSG_THREADS Number of threads responsible for handling messages.
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_SELECTORS_CNT Default count of selectors for tcp server equals to the count of processors in system.

Constructor Summary

GridTcpCommunicationSpi()

Method Summary

protected void	checkConfigurationConsistency(GridNode node, boolean starting) Checks remote node SPI configuration and prints warnings if necessary.
int	getConnectTimeout() Gets connect timeout used when establishing connection with remote nodes.
protected List<String>	getConsistentAttributeNames() Returns back a list of attributes that should be consistent for this SPI.
long	getIdleConnectionTimeout() Gets maximum idle connection time upon which idle connections will be closed.
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.
int	getMaxOpenClients() Gets maximum count of simultaneously open TCP clients for one remote node.
int	getMessageThreads() Gets number of threads used for handling NIO messages.
int	getNioActiveThreadCount() Returns the approximate number of threads that are actively processing NIO tasks.
int	getNioCorePoolSize() Returns the core number of NIO threads.
int	getNioLargestPoolSize() Returns the largest number of NIO threads that have ever simultaneously been in the pool.
int	getNioMaximumPoolSize() Returns the maximum allowed number of NIO threads.
int	getNioPoolSize() Returns the current number of NIO threads in the pool.
int	getNioTaskQueueSize() Gets current size of the NIO queue size.
long	getNioTotalCompletedTaskCount() Returns the approximate total number of NIO tasks that have completed execution.
long	getNioTotalScheduledTaskCount() Returns the approximate total number of NIO tasks that have been scheduled for execution.
Map<String,Object>	getNodeAttributes() This method is called before SPI starts (before method GridSpi.spiStart(String) is called).
long	getReceivedBytesCount() Gets received bytes count.
int	getReceivedMessagesCount() Gets received messages count.
int	getSelectorsCount() Gets count of selectors used in TCP server.
long	getSentBytesCount() Gets sent bytes count.
int	getSentMessagesCount() Gets sent messages count.
GridSpiPortResolver	getSpiPortResolver() Gets port resolver for ports mapping determination.
boolean	isDirectBuffer() Gets flag that indicates whether direct or heap allocated buffer is used.
protected void	notifyListener(org.gridgain.grid.spi.communication.tcp.GridTcpCommunicationMessage msg)
void	onContextDestroyed() Callback invoked prior to stopping grid before SPI context is destroyed.
void	onContextInitialized(GridSpiContext spiCtx) Callback invoked when SPI context is initialized.
void	sendMessage(Collection<? extends GridNode> destNodes, Serializable msg) Sends given message to destination nodes.
void	sendMessage(GridNode destNode, Serializable msg) Sends given message to destination node.
void	setConnectTimeout(int 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	setIdleConnectionTimeout(long idleConnTimeout) Sets maximum idle connection timeout upon which a connection to client will be closed.
void	setListener(GridMessageListener lsnr) Set communication listener.
void	setLocalAddress(String localAddr) Sets local host address for socket binding.
void	setLocalPort(int localPort) Sets local port for socket binding.
void	setLocalPortRange(int localPortRange) Sets local port range for local host ports (value must greater than or equal to 0).
void	setMaxOpenClients(int maxOpenClients) Sets the maximum count of simultaneously open clients per remote node.
void	setMessageThreads(int msgThreads) Number of threads used for handling messages received by NIO server.
void	setSelectorsCount(int selectorsCnt) Sets the count of selectors te be used in TCP server.
void	setSpiPortResolver(GridSpiPortResolver portRsvr) Sets port resolver for ports mapping determination.
void	spiStart(String gridName) This method is called to start SPI.
void	spiStop() This method is called to stop SPI.
String	toString()

Methods inherited from class org.gridgain.grid.spi.GridSpiAdapter

assertParameter, configInfo, createSpiAttributeName, getAuthor, getGridGainHome, getLocalNodeId, getName, getSpiContext, getStartTimestamp, getStartTimestampFormatted, getUpTime, getUpTimeFormatted, getVendorEmail, getVendorUrl, getVersion, injectables, registerMBean, setJson, setName, startInfo, startStopwatch, stopInfo, unregisterMBean

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.gridgain.grid.spi.GridSpi

getName

Methods inherited from interface org.gridgain.grid.spi.GridSpiJsonConfigurable

setJson

Methods inherited from interface org.gridgain.grid.spi.GridSpiManagementMBean

getAuthor, getGridGainHome, getLocalNodeId, getName, getStartTimestamp, getStartTimestampFormatted, getUpTime, getUpTimeFormatted, getVendorEmail, getVendorUrl, getVersion

Field Detail

DFLT_MSG_THREADS

public static final int DFLT_MSG_THREADS

Number of threads responsible for handling messages.

See Also:

Constant Field Values

ATTR_ADDR

public static final String ATTR_ADDR

Node attribute that is mapped to node IP address (value is comm.tcp.addr).

See Also:

Constant Field Values

ATTR_PORT

public static final String ATTR_PORT

Node attribute that is mapped to node port number (value is comm.tcp.port).

See Also:

Constant Field Values

ATTR_EXT_PORTS

public static final String ATTR_EXT_PORTS

Node attribute that is mapped to node's external ports numbers (value is comm.tcp.ext-ports).

See Also:

Constant Field Values

DFLT_PORT

public static final int DFLT_PORT

Default port which node sets listener to (value is 47100).

See Also:

Constant Field Values

DFLT_IDLE_CONN_TIMEOUT

public static final int DFLT_IDLE_CONN_TIMEOUT

Default idle connection timeout (value is 30000ms).

See Also:

Constant Field Values

DFLT_CONN_TIMEOUT

public static final int DFLT_CONN_TIMEOUT

Default connection timeout (value is 1000ms).

See Also:

Constant Field Values

DFLT_MAX_OPEN_CLIENTS

public static final int DFLT_MAX_OPEN_CLIENTS

Default maximum count of simultaneously open client for one node (value is 1).

See Also:

Constant Field Values

DFLT_SELECTORS_CNT

public static final int DFLT_SELECTORS_CNT

Default count of selectors for tcp server equals to the count of processors in system.

DFLT_PORT_RANGE

public static final int DFLT_PORT_RANGE

Default local port range (value is 100). See GridTcpCommunicationSpi.setLocalPortRange(int) for details.

See Also:

Constant Field Values

Constructor Detail

GridTcpCommunicationSpi

public GridTcpCommunicationSpi()

Method Detail

setLocalAddress

@GridSpiConfiguration(optional=true)
@GridLocalHostResource
public void setLocalAddress(String localAddr)

Sets local host address for socket binding. Note that one node could have additional addresses beside the loopback one. This configuration parameter is optional.

Parameters:

localAddr - IP address. Default value is any available local IP address.

getLocalAddress

public String getLocalAddress()

Gets local host address for socket binding. Beside loopback address physical node could have several other ones, but only one is assigned to grid node.

Specified by:

getLocalAddress in interface GridTcpCommunicationSpiMBean

Returns:

Grid node IP address.

setMessageThreads

@GridSpiConfiguration(optional=true)
public void setMessageThreads(int msgThreads)

Number of threads used for handling messages received by NIO server. This number usually should be no less than number of CPUs.

If not provided, default value is GridTcpCommunicationSpi.DFLT_MSG_THREADS.

Parameters:

msgThreads - Number of threads.

getMessageThreads

public int getMessageThreads()

Gets number of threads used for handling NIO messages.

Specified by:

getMessageThreads in interface GridTcpCommunicationSpiMBean

Returns:

Number of threads used for handling NIO messages.

setLocalPort

@GridSpiConfiguration(optional=true)
public void setLocalPort(int localPort)

Sets local port for socket binding.

If not provided, default value is GridTcpCommunicationSpi.DFLT_PORT.

Parameters:

localPort - Port number.

getLocalPort

public int getLocalPort()

Gets local port for socket binding.

Specified by:

getLocalPort in interface GridTcpCommunicationSpiMBean

Returns:

Port number.

setLocalPortRange

@GridSpiConfiguration(optional=true)
public void setLocalPortRange(int localPortRange)

Sets local port range for local host ports (value must greater than or equal to 0). If provided local port (see GridTcpCommunicationSpi.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 GridTcpCommunicationSpi.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 GridTcpCommunicationSpi.DFLT_PORT_RANGE.

Parameters:

localPortRange - New local port range.

getLocalPortRange

public int getLocalPortRange()

Gets maximum number of local ports tried if all previously tried ports are occupied.

Specified by:

getLocalPortRange in interface GridTcpCommunicationSpiMBean

Returns:

Local port range.

setSpiPortResolver

@GridSpiConfiguration(optional=true)
public void setSpiPortResolver(GridSpiPortResolver portRsvr)

Sets port resolver for ports mapping determination.

Parameters:

portRsvr - Port resolver.

getSpiPortResolver

public GridSpiPortResolver getSpiPortResolver()

Gets port resolver for ports mapping determination.

Specified by:

getSpiPortResolver in interface GridTcpCommunicationSpiMBean

Returns:

Port resolver for ports mapping determination.

setIdleConnectionTimeout

@GridSpiConfiguration(optional=true)
public void setIdleConnectionTimeout(long idleConnTimeout)

Sets maximum idle connection timeout upon which a connection to client will be closed.

If not provided, default value is GridTcpCommunicationSpi.DFLT_IDLE_CONN_TIMEOUT.

Parameters:

idleConnTimeout - Maximum idle connection time.

getIdleConnectionTimeout

public long getIdleConnectionTimeout()

Gets maximum idle connection time upon which idle connections will be closed.

Specified by:

getIdleConnectionTimeout in interface GridTcpCommunicationSpiMBean

Returns:

Maximum idle connection time.

setConnectTimeout

@GridSpiConfiguration(optional=true)
public void setConnectTimeout(int connTimeout)

Sets connect timeout used when establishing connection with remote nodes.

0 is interpreted as infinite timeout.

If not provided, default value is GridTcpCommunicationSpi.DFLT_CONN_TIMEOUT.

Parameters:

connTimeout - Connect timeout.

getConnectTimeout

public int getConnectTimeout()

Gets connect timeout used when establishing connection with remote nodes.

Specified by:

getConnectTimeout in interface GridTcpCommunicationSpiMBean

Returns:

Connect timeout.

setDirectBuffer

@GridSpiConfiguration(optional=true)
public void setDirectBuffer(boolean directBuf)

Sets flag to allocate direct or heap buffer in SPI. If value is true, then SPI will use ByteBuffer.allocateDirect(int) call. Otherwise, SPI will use ByteBuffer.allocate(int) call.

If not provided, default value is true.

Parameters:

directBuf - Flag indicates to allocate direct or heap buffer in SPI.

isDirectBuffer

public boolean isDirectBuffer()

Gets flag that indicates whether direct or heap allocated buffer is used.

Specified by:

isDirectBuffer in interface GridTcpCommunicationSpiMBean

Returns:

Flag that indicates whether direct or heap allocated buffer is used.

setMaxOpenClients

@GridSpiConfiguration(optional=true)
public void setMaxOpenClients(int maxOpenClients)

Sets the maximum count of simultaneously open clients per remote node.

If not provided, default value is GridTcpCommunicationSpi.DFLT_MAX_OPEN_CLIENTS.

Parameters:

maxOpenClients - Maximum count of open TCP clients per node.

getMaxOpenClients

public int getMaxOpenClients()

Gets maximum count of simultaneously open TCP clients for one remote node.

Specified by:

getMaxOpenClients in interface GridTcpCommunicationSpiMBean

Returns:

Maximum count of open TCP clients per node.

setSelectorsCount

@GridSpiConfiguration(optional=true)
public void setSelectorsCount(int selectorsCnt)

Sets the count of selectors te be used in TCP server.

If not provided, default value is GridTcpCommunicationSpi.DFLT_SELECTORS_CNT.

Parameters:

selectorsCnt - Selectors count.

getSelectorsCount

public int getSelectorsCount()

Gets count of selectors used in TCP server. Default value equals to the number of CPUs available in the system.

Specified by:

getSelectorsCount in interface GridTcpCommunicationSpiMBean

Returns:

Count of selectors in TCP server.

setListener

public void setListener(GridMessageListener lsnr)

Set communication listener.

Specified by:

setListener in interface GridCommunicationSpi

Parameters:

lsnr - Listener to set or null to unset the listener.

getNioActiveThreadCount

public int getNioActiveThreadCount()

Returns the approximate number of threads that are actively processing NIO tasks.

Specified by:

getNioActiveThreadCount in interface GridTcpCommunicationSpiMBean

Returns:

Approximate number of threads that are actively processing NIO tasks.

getNioTotalCompletedTaskCount

public long getNioTotalCompletedTaskCount()

Returns the approximate total number of NIO tasks that have completed execution. Because the states of tasks and threads may change dynamically during computation, the returned value is only an approximation, but one that does not ever decrease across successive calls.

Specified by:

getNioTotalCompletedTaskCount in interface GridTcpCommunicationSpiMBean

Returns:

Approximate total number of NIO tasks that have completed execution.

getNioCorePoolSize

public int getNioCorePoolSize()

Returns the core number of NIO threads.

Specified by:

getNioCorePoolSize in interface GridTcpCommunicationSpiMBean

Returns:

Core number of NIO threads.

getNioLargestPoolSize

public int getNioLargestPoolSize()

Returns the largest number of NIO threads that have ever simultaneously been in the pool.

Specified by:

getNioLargestPoolSize in interface GridTcpCommunicationSpiMBean

Returns:

Largest number of NIO threads that have ever simultaneously been in the pool.

getNioMaximumPoolSize

public int getNioMaximumPoolSize()

Returns the maximum allowed number of NIO threads.

Specified by:

getNioMaximumPoolSize in interface GridTcpCommunicationSpiMBean

Returns:

Maximum allowed number of NIO threads.

getNioPoolSize

public int getNioPoolSize()

Returns the current number of NIO threads in the pool.

Specified by:

getNioPoolSize in interface GridTcpCommunicationSpiMBean

Returns:

Current number of NIO threads in the pool.

getNioTotalScheduledTaskCount

public long getNioTotalScheduledTaskCount()

Returns the approximate total number of NIO tasks that have been scheduled for execution. Because the states of tasks and threads may change dynamically during computation, the returned value is only an approximation, but one that does not ever decrease across successive calls.

Specified by:

getNioTotalScheduledTaskCount in interface GridTcpCommunicationSpiMBean

Returns:

Approximate total number of NIO tasks that have been scheduled for execution.

getNioTaskQueueSize

public int getNioTaskQueueSize()

Gets current size of the NIO queue size. NIO queue buffers NIO tasks when there are not threads available for processing in the pool.

Specified by:

getNioTaskQueueSize in interface GridTcpCommunicationSpiMBean

Returns:

Current size of the NIO queue size.

getSentMessagesCount

public int getSentMessagesCount()

Gets sent messages count.

Specified by:

getSentMessagesCount in interface GridTcpCommunicationSpiMBean

Returns:

Sent messages count.

getSentBytesCount

public long getSentBytesCount()

Gets sent bytes count.

Specified by:

getSentBytesCount in interface GridTcpCommunicationSpiMBean

Returns:

Sent bytes count.

getReceivedMessagesCount

public int getReceivedMessagesCount()

Gets received messages count.

Specified by:

getReceivedMessagesCount in interface GridTcpCommunicationSpiMBean

Returns:

Received messages count.

getReceivedBytesCount

public long getReceivedBytesCount()

Gets received bytes count.

Specified by:

getReceivedBytesCount in interface GridTcpCommunicationSpiMBean

Returns:

Received bytes count.

getNodeAttributes

public Map<String,Object> getNodeAttributes()
                                     throws GridSpiException

This method is called before SPI starts (before method GridSpi.spiStart(String) is called). It allows SPI implementation to add attributes to a local node. Kernel 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.

Specified by:

getNodeAttributes in interface GridSpi

Overrides:

getNodeAttributes in class GridSpiAdapter

Throws:

GridSpiException - Throws in case of any error.

Returns:

Map of local node attributes this SPI wants to add.

spiStart

public void spiStart(String gridName)
              throws GridSpiException

This method is called to start SPI. After this method returns successfully kernel assumes that SPI is fully operational.

Specified by:

spiStart in interface GridSpi

Throws:

GridSpiException - Throws in case of any error during SPI start.

Parameters:

gridName - Name of grid instance this SPI is being started for (null for default grid).

onContextInitialized

public void onContextInitialized(GridSpiContext spiCtx)
                          throws GridSpiException

Callback invoked when SPI context is initialized. SPI implementation may store SPI context for future access.

This method is invoked after GridSpi.spiStart(String) method is completed, so SPI should be fully functional at this point. Use this method for post-start initialization, such as subscribing a discovery listener, sending a message to remote node, etc... }

Specified by:

onContextInitialized in interface GridSpi

Overrides:

onContextInitialized in class GridSpiAdapter

Throws:

GridSpiException - If context initialization failed (grid will be stopped).

Parameters:

spiCtx - Spi context.

spiStop

public void spiStop()
             throws GridSpiException

This method is called to stop SPI. After this method returns kernel assumes that this SPI is finished and all resources acquired by it are released.

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.

Specified by:

spiStop in interface GridSpi

Throws:

GridSpiException - Thrown in case of any error during SPI stop.

onContextDestroyed

public void onContextDestroyed()

Callback invoked prior to stopping grid before SPI context is destroyed. Once this method is complete, grid will begin shutdown sequence. Use this callback for de-initialization logic that may involve SPI context. Note that invoking SPI context after this callback is complete is considered illegal and may produce unknown results.

If GridSpiAdapter is used for SPI implementation, then it will replace actual context with dummy no-op context which is usually good-enough since grid is about to shut down.

Specified by:

onContextDestroyed in interface GridSpi

Overrides:

onContextDestroyed in class GridSpiAdapter

checkConfigurationConsistency

protected void checkConfigurationConsistency(GridNode node,
                                             boolean starting)

Checks remote node SPI configuration and prints warnings if necessary.

Overrides:

checkConfigurationConsistency in class GridSpiAdapter

Parameters:

node - Remote node.

starting - Flag indicating whether this method is called during SPI start or during node joined event.

sendMessage

public void sendMessage(GridNode destNode,
                        Serializable msg)
                 throws GridSpiException

Sends given message to destination node. Note that characteristics of the exchange such as durability, guaranteed delivery or error notification is dependant on SPI implementation.

Specified by:

sendMessage in interface GridCommunicationSpi

Throws:

GridSpiException - 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.

Parameters:

destNode - Destination node.

msg - Message to send.

sendMessage

public void sendMessage(Collection<? extends GridNode> destNodes,
                        Serializable msg)
                 throws GridSpiException

Sends given message to destination nodes. Note that characteristics of the exchange such as durability, guaranteed delivery or error notification is dependant on SPI implementation.

Specified by:

sendMessage in interface GridCommunicationSpi

Throws:

GridSpiException - 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.

Parameters:

destNodes - Destination nodes.

msg - Message to send.

notifyListener

protected void notifyListener(org.gridgain.grid.spi.communication.tcp.GridTcpCommunicationMessage msg)

Parameters:

msg - Communication message.

getConsistentAttributeNames

protected List<String> getConsistentAttributeNames()

Returns back a list of attributes that should be consistent for this SPI. Consistency means that remote node has to have the same attribute with the same value.

Overrides:

getConsistentAttributeNames in class GridSpiAdapter

Returns:

List or attribute names.

toString

public String toString()

Overrides:

toString in class Object