org.gridgain.grid.spi.communication

Interface GridCommunicationSpi<T extends Serializable>

All Superinterfaces:

GridSpi

All Known Implementing Classes:

GridTcpCommunicationSpi

public interface GridCommunicationSpi<T extends Serializable>
extends GridSpi

Communication SPI is responsible for data exchange between nodes.

Communication SPI is one of the most important SPI in GridGain. It is used heavily throughout the system and provides means for all data exchanges between nodes, such as internal implementation details and user driven messages.

Functionality to this SPI is exposed directly in Grid interface:

• GridMessaging.send(Object, Object)
• GridMessaging.send(Object, Collection)

GridGain comes with built-in communication SPI implementations:

• GridTcpCommunicationSpi

NOTE: this SPI (i.e. methods in this interface) should never be used directly. SPIs provide internal view on the subsystem and is used internally by GridGain kernal. In rare use cases when access to a specific implementation of this SPI is required - an instance of this SPI can be obtained via Grid.configuration() method to check its configuration properties or call other non-SPI methods. Note again that calling methods from this interface on the obtained instance can lead to undefined behavior and explicitly not supported.

Method Summary

Methods

Modifier and Type	Method and Description
int	getOutboundMessagesQueueSize() Gets outbound messages queue size.
long	getReceivedBytesCount() Gets received bytes count.
int	getReceivedMessagesCount() Gets received messages count.
long	getSentBytesCount() Gets sent bytes count.
int	getSentMessagesCount() Gets sent messages count.
void	resetMetrics() Resets metrics for this SPI instance.
void	sendMessage(GridNode destNode, T msg) Sends given message to destination node.
void	setListener(GridCommunicationListener<T> lsnr) Set communication listener.

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

getName, getNodeAttributes, onContextDestroyed, onContextInitialized, spiStart, spiStop

Method Detail

sendMessage

void sendMessage(GridNode destNode,
               T 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.

Parameters:

destNode - Destination node.

msg - Message to send.

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.

getSentMessagesCount

int getSentMessagesCount()

Gets sent messages count.

Returns:

Sent messages count.

getSentBytesCount

long getSentBytesCount()

Gets sent bytes count.

Returns:

Sent bytes count.

getReceivedMessagesCount

int getReceivedMessagesCount()

Gets received messages count.

Returns:

Received messages count.

getReceivedBytesCount

long getReceivedBytesCount()

Gets received bytes count.

Returns:

Received bytes count.

getOutboundMessagesQueueSize

int getOutboundMessagesQueueSize()

Gets outbound messages queue size.

Returns:

Outbound messages queue size.

resetMetrics

void resetMetrics()

Resets metrics for this SPI instance.

setListener

void setListener(@Nullable
               GridCommunicationListener<T> lsnr)

Set communication listener.

Parameters:

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