Uses of Class
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage

Packages that use TcpDiscoveryAbstractMessage

Package	Description
org.apache.ignite.spi.discovery.tcp	Contains default TCP/IP implementation for discovery SPI.
org.apache.ignite.spi.discovery.tcp.internal	Contains internal implementation.
org.apache.ignite.spi.discovery.tcp.messages	Contains implementation messages.

Uses of TcpDiscoveryAbstractMessage in org.apache.ignite.spi.discovery.tcp

Fields in org.apache.ignite.spi.discovery.tcp with type parameters of type TcpDiscoveryAbstractMessage

Modifier and Type	Field and Description
protected CopyOnWriteArrayList<IgniteInClosure<TcpDiscoveryAbstractMessage>>	TcpDiscoverySpi.sndMsgLsnrs

Methods in org.apache.ignite.spi.discovery.tcp with parameters of type TcpDiscoveryAbstractMessage

Modifier and Type	Method and Description
protected boolean	TcpDiscoverySpi.ensured(TcpDiscoveryAbstractMessage msg)
protected void	TcpDiscoverySpi.writeToSocket(Socket sock, OutputStream out, TcpDiscoveryAbstractMessage msg, long timeout) Writes message to the socket.
protected void	TcpDiscoverySpi.writeToSocket(Socket sock, TcpDiscoveryAbstractMessage msg, byte[] data, long timeout) Writes message to the socket.
protected void	TcpDiscoverySpi.writeToSocket(Socket sock, TcpDiscoveryAbstractMessage msg, long timeout) Writes message to the socket.
protected void	TcpDiscoverySpi.writeToSocket(TcpDiscoveryAbstractMessage msg, Socket sock, int res, long timeout) Writes response to the socket.

Method parameters in org.apache.ignite.spi.discovery.tcp with type arguments of type TcpDiscoveryAbstractMessage

Modifier and Type	Method and Description
void	TcpDiscoverySpi.addSendMessageListener(IgniteInClosure<TcpDiscoveryAbstractMessage> lsnr) FOR TEST ONLY!!!
void	TcpDiscoverySpi.removeSendMessageListener(IgniteInClosure<TcpDiscoveryAbstractMessage> lsnr) FOR TEST ONLY!!!

Uses of TcpDiscoveryAbstractMessage in org.apache.ignite.spi.discovery.tcp.internal

Methods in org.apache.ignite.spi.discovery.tcp.internal with parameters of type TcpDiscoveryAbstractMessage

Modifier and Type	Method and Description
void	TcpDiscoveryStatistics.onMessageProcessingFinished(TcpDiscoveryAbstractMessage msg) Collects necessary stats for message processed by SPI.
void	TcpDiscoveryStatistics.onMessageProcessingStarted(TcpDiscoveryAbstractMessage msg) Collects necessary stats for message processed by SPI.
void	TcpDiscoveryStatistics.onMessageReceived(TcpDiscoveryAbstractMessage msg) Collects necessary stats for message received by SPI.
void	TcpDiscoveryStatistics.onMessageSent(TcpDiscoveryAbstractMessage msg, long time) Called by coordinator when ring message is sent.
void	TcpDiscoveryStatistics.onRingMessageReceived(TcpDiscoveryAbstractMessage msg) Called by coordinator when ring message makes full pass.

Uses of TcpDiscoveryAbstractMessage in org.apache.ignite.spi.discovery.tcp.messages

Subclasses of TcpDiscoveryAbstractMessage in org.apache.ignite.spi.discovery.tcp.messages

Modifier and Type	Class and Description
class	TcpDiscoveryAuthFailedMessage Message telling joining node that its authentication failed on coordinator.
class	TcpDiscoveryCheckFailedMessage Message telling joining node that it failed coordinator's validation check.
class	TcpDiscoveryClientAckResponse
class	TcpDiscoveryClientMetricsUpdateMessage Metrics update message.
class	TcpDiscoveryClientPingRequest Ping request.
class	TcpDiscoveryClientPingResponse Ping request.
class	TcpDiscoveryClientReconnectMessage Message telling that client node is reconnecting to topology.
class	TcpDiscoveryConnectionCheckMessage Message used to check whether a node is still connected to the topology.
class	TcpDiscoveryCustomEventMessage Wrapped for custom message.
class	TcpDiscoveryDiscardMessage Message sent by coordinator when some operation handling is over.
class	TcpDiscoveryDuplicateIdMessage Message telling joining node that new topology already contain different node with same ID.
class	TcpDiscoveryHandshakeRequest Handshake request.
class	TcpDiscoveryHandshakeResponse Handshake response.
class	TcpDiscoveryJoinRequestMessage Initial message sent by a node that wants to enter topology.
class	TcpDiscoveryLoopbackProblemMessage Message telling joining node that it has loopback problem (misconfiguration).
class	TcpDiscoveryMetricsUpdateMessage Metrics update message.
class	TcpDiscoveryNodeAddedMessage Message telling nodes that new node should be added to topology.
class	TcpDiscoveryNodeAddFinishedMessage Sent by coordinator across the ring to finish node add process.
class	TcpDiscoveryNodeFailedMessage Sent by node that has detected node failure to coordinator across the ring, then sent by coordinator across the ring.
class	TcpDiscoveryNodeLeftMessage Sent by node that is stopping to coordinator across the ring, then sent by coordinator across the ring.
class	TcpDiscoveryPingRequest Ping request.
class	TcpDiscoveryPingResponse Ping response.
class	TcpDiscoveryStatusCheckMessage Message sent by node to its next to ensure that next node and connection to it are alive.

Methods in org.apache.ignite.spi.discovery.tcp.messages that return types with arguments of type TcpDiscoveryAbstractMessage

Modifier and Type	Method and Description
Collection<TcpDiscoveryAbstractMessage>	TcpDiscoveryNodeAddedMessage.messages() Gets pending messages sent to new node by its previous.
Collection<TcpDiscoveryAbstractMessage>	TcpDiscoveryClientReconnectMessage.pendingMessages()

Method parameters in org.apache.ignite.spi.discovery.tcp.messages with type arguments of type TcpDiscoveryAbstractMessage

Modifier and Type	Method and Description
void	TcpDiscoveryNodeAddedMessage.messages(Collection<TcpDiscoveryAbstractMessage> msgs, IgniteUuid discardMsgId, IgniteUuid discardCustomMsgId) Sets pending messages to send to new node.
void	TcpDiscoveryClientReconnectMessage.pendingMessages(Collection<TcpDiscoveryAbstractMessage> msgs)

Constructors in org.apache.ignite.spi.discovery.tcp.messages with parameters of type TcpDiscoveryAbstractMessage

Constructor and Description
TcpDiscoveryAbstractMessage(TcpDiscoveryAbstractMessage msg)