Package org.apache.ignite.spi.communication.tcp.internal

Contains connection health-checkers for TCP/IP-based implementation of communication SPI.

Interface Summary

Interface	Description
CommunicationListenerEx<T extends Serializable>	Extended communication SPI listener to provide Channel opened events.
ConnectionPolicy	Connection policy.
ConnectionRequestor	Helper interface to ask other nodes to open connections.
TcpCommunicationNodeConnectionCheckFuture	Tcp Communication Node Connection Check Future.
TcpConnectionIndexAwareMessage

Class Summary

Class	Description
ClusterStateProvider	Deprecated. This class must be removed.
CommunicationDiscoveryEventListener	Listener on discovery events.
CommunicationTcpUtils	Common communication spi logic.
CommunicationWorker	Works with connections states.
ConnectFuture	Connect future which uses as a marker of type connection releted with TCP.
ConnectGateway	Lock and error control work flow.
ConnectionClientPool	Registry of client connections.
ConnectionKey	Connection Key.
ConnectionRequestFuture	Marker future implementation, just like ConnectFuture, but meaning that we're waiting for the inverse connection.
DisconnectedSessionInfo	Class marker that say that connection must be interacted.
FirstConnectionPolicy	First connection policy.
GridNioServerWrapper	Deprecated. Should be removed.
HandshakeTimeoutObject	Callback that is intended to be executed after timeout on handshake.
InboundConnectionHandler	This class implement NioListener which process handshake stage, and transmit messages to session.
RoundRobinConnectionPolicy	Round robin connection policy.
TcpCommunicationConfigInitializer	Only may implement it TcpCommunicationSpi.
TcpCommunicationConfiguration	Class of configuration for TcpCommunicationSpi segregation.
TcpCommunicationConnectionCheckFuture	Tcp Communication Connection Check Future.
TcpCommunicationSpiMBeanImpl	MBean implementation for TcpCommunicationSpi.
TcpConnectionRequestDiscoveryMessage	Message is part of communication via discovery protocol.
TcpHandshakeExecutor	Executor for synchronously establishing a connection with a node.
TcpInverseConnectionResponseMessage	Inverse connection response message sent by client node as a response to inverse connection request received by discovery.

Exception Summary

Exception	Description
HandshakeException	Internal exception class for proper timeout handling.
NodeUnreachableException	Exception is thrown by TcpCommunicationSpi when some or all addresses of a node are unreachable and direct communication connection cannot be established.