Class RecoveryLastReceivedMessage
- java.lang.Object
-
- org.apache.ignite.spi.communication.tcp.messages.RecoveryLastReceivedMessage
-
-
Field Summary
Fields Modifier and Type Field Description static longALREADY_CONNECTEDstatic intMESSAGE_FULL_SIZEFull message size (with message type) in bytes.static longNEED_WAITNeed wait.static longNODE_STOPPINGstatic longUNKNOWN_NODEInitiator node is not in current topogy.-
Fields inherited from interface org.apache.ignite.plugin.extensions.communication.Message
DIRECT_TYPE_SIZE
-
-
Constructor Summary
Constructors Constructor Description RecoveryLastReceivedMessage()Default constructor.RecoveryLastReceivedMessage(long rcvCnt)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description shortdirectType()Gets message type.longreceived()voidreceived(long rcvCnt)StringtoString()
-
-
-
Field Detail
-
ALREADY_CONNECTED
public static final long ALREADY_CONNECTED
- See Also:
- Constant Field Values
-
NODE_STOPPING
public static final long NODE_STOPPING
- See Also:
- Constant Field Values
-
NEED_WAIT
public static final long NEED_WAIT
Need wait.- See Also:
- Constant Field Values
-
UNKNOWN_NODE
public static final long UNKNOWN_NODE
Initiator node is not in current topogy.- See Also:
- Constant Field Values
-
MESSAGE_FULL_SIZE
public static final int MESSAGE_FULL_SIZE
Full message size (with message type) in bytes.- See Also:
- Constant Field Values
-
-
Method Detail
-
received
public long received()
- Returns:
- Number of received messages.
-
received
public void received(long rcvCnt)
- Parameters:
rcvCnt- Number of received messages.
-
directType
public short directType()
Gets message type.- Specified by:
directTypein interfaceMessage- Returns:
- Message type.
-
-