Class RecoveryLastReceivedMessage
- java.lang.Object
-
- org.apache.ignite.spi.communication.tcp.messages.RecoveryLastReceivedMessage
-
- All Implemented Interfaces:
Serializable,Message
public class RecoveryLastReceivedMessage extends Object implements Message
Recovery acknowledgment message.- See Also:
- Serialized Form
-
-
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 required byMessage.RecoveryLastReceivedMessage(long rcvCnt)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description shortdirectType()Gets message type.bytefieldsCount()Gets fields count.voidonAckReceived()Method called when ack message received.booleanreadFrom(ByteBuffer buf, MessageReader reader)Reads this message from provided byte buffer.longreceived()StringtoString()booleanwriteTo(ByteBuffer buf, MessageWriter writer)Writes this message to provided byte buffer.
-
-
-
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
-
-
Constructor Detail
-
RecoveryLastReceivedMessage
public RecoveryLastReceivedMessage()
Default constructor required byMessage.
-
RecoveryLastReceivedMessage
public RecoveryLastReceivedMessage(long rcvCnt)
- Parameters:
rcvCnt- Number of received messages.
-
-
Method Detail
-
received
public long received()
- Returns:
- Number of received messages.
-
onAckReceived
public void onAckReceived()
Method called when ack message received.- Specified by:
onAckReceivedin interfaceMessage
-
writeTo
public boolean writeTo(ByteBuffer buf, MessageWriter writer)
Writes this message to provided byte buffer.
-
readFrom
public boolean readFrom(ByteBuffer buf, MessageReader reader)
Reads this message from provided byte buffer.
-
directType
public short directType()
Gets message type.- Specified by:
directTypein interfaceMessage- Returns:
- Message type.
-
fieldsCount
public byte fieldsCount()
Gets fields count.- Specified by:
fieldsCountin interfaceMessage- Returns:
- Fields count.
-
-