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 SummaryFields 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.MessageDIRECT_TYPE_SIZE
 
- 
 - 
Constructor SummaryConstructors Constructor Description RecoveryLastReceivedMessage()Default constructor required byMessage.RecoveryLastReceivedMessage(long rcvCnt)
 - 
Method SummaryAll 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_CONNECTEDpublic static final long ALREADY_CONNECTED - See Also:
- Constant Field Values
 
 - 
NODE_STOPPINGpublic static final long NODE_STOPPING - See Also:
- Constant Field Values
 
 - 
NEED_WAITpublic static final long NEED_WAIT Need wait.- See Also:
- Constant Field Values
 
 - 
UNKNOWN_NODEpublic static final long UNKNOWN_NODE Initiator node is not in current topogy.- See Also:
- Constant Field Values
 
 - 
MESSAGE_FULL_SIZEpublic static final int MESSAGE_FULL_SIZE Full message size (with message type) in bytes.- See Also:
- Constant Field Values
 
 
- 
 - 
Constructor Detail- 
RecoveryLastReceivedMessagepublic RecoveryLastReceivedMessage() Default constructor required byMessage.
 - 
RecoveryLastReceivedMessagepublic RecoveryLastReceivedMessage(long rcvCnt) - Parameters:
- rcvCnt- Number of received messages.
 
 
- 
 - 
Method Detail- 
receivedpublic long received() - Returns:
- Number of received messages.
 
 - 
onAckReceivedpublic void onAckReceived() Method called when ack message received.- Specified by:
- onAckReceivedin interface- Message
 
 - 
writeTopublic boolean writeTo(ByteBuffer buf, MessageWriter writer) Writes this message to provided byte buffer.
 - 
readFrompublic boolean readFrom(ByteBuffer buf, MessageReader reader) Reads this message from provided byte buffer.
 - 
directTypepublic short directType() Gets message type.- Specified by:
- directTypein interface- Message
- Returns:
- Message type.
 
 - 
fieldsCountpublic byte fieldsCount() Gets fields count.- Specified by:
- fieldsCountin interface- Message
- Returns:
- Fields count.
 
 
- 
 
-