Class TcpDiscoveryClientReconnectMessage
- java.lang.Object
-
- org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage
-
- org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryClientReconnectMessage
-
- All Implemented Interfaces:
Serializable
@TcpDiscoveryEnsureDelivery public class TcpDiscoveryClientReconnectMessage extends TcpDiscoveryAbstractMessage
Message telling that client node is reconnecting to topology.- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from class org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage
CHANGE_TOPOLOGY_FLAG_POS, CLIENT_ACK_FLAG_POS, CLIENT_FLAG_POS, CLIENT_RECON_SUCCESS_FLAG_POS, FORCE_FAIL_FLAG_POS, RESPONDED_FLAG_POS
-
-
Constructor Summary
Constructors Constructor Description TcpDiscoveryClientReconnectMessage(UUID creatorNodeId, UUID routerNodeId, IgniteUuid lastMsgId)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object obj)IgniteUuidlastMessageId()Collection<TcpDiscoveryAbstractMessage>pendingMessages()voidpendingMessages(Collection<TcpDiscoveryAbstractMessage> msgs)UUIDrouterNodeId()booleansuccess()voidsuccess(boolean success)StringtoString()-
Methods inherited from class org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage
addFailedNode, client, client, creatorNodeId, failedNodes, failedNodes, force, force, getFlag, hashCode, highPriority, id, pendingIndex, pendingIndex, senderNodeId, senderNodeId, setFlag, topologyVersion, topologyVersion, traceLogLevel, verified, verifierNodeId, verify
-
-
-
-
Constructor Detail
-
TcpDiscoveryClientReconnectMessage
public TcpDiscoveryClientReconnectMessage(UUID creatorNodeId, UUID routerNodeId, IgniteUuid lastMsgId)
- Parameters:
creatorNodeId- Creator node ID.routerNodeId- New router node ID.lastMsgId- Last message ID.
-
-
Method Detail
-
routerNodeId
public UUID routerNodeId()
- Returns:
- New router node ID.
-
lastMessageId
public IgniteUuid lastMessageId()
- Returns:
- Last message ID.
-
pendingMessages
public void pendingMessages(Collection<TcpDiscoveryAbstractMessage> msgs)
- Parameters:
msgs- Pending messages.
-
pendingMessages
public Collection<TcpDiscoveryAbstractMessage> pendingMessages()
- Returns:
- Pending messages.
-
success
public void success(boolean success)
- Parameters:
success- Success flag.
-
success
public boolean success()
- Returns:
- Success flag.
-
equals
public boolean equals(Object obj)
- Overrides:
equalsin classTcpDiscoveryAbstractMessage
-
toString
public String toString()
- Overrides:
toStringin classTcpDiscoveryAbstractMessage
-
-