public static class TcpCommunicationSpi.RecoveryLastReceivedMessage extends MessageAdapter
MessageAdapter.Type
reader, readState
Constructor and Description |
---|
TcpCommunicationSpi.RecoveryLastReceivedMessage()
Default constructor required by
MessageAdapter . |
TcpCommunicationSpi.RecoveryLastReceivedMessage(long rcvCnt) |
Modifier and Type | Method and Description |
---|---|
byte |
directType()
Gets message type.
|
boolean |
readFrom(ByteBuffer buf)
Reads this message from provided byte buffer.
|
long |
received() |
boolean |
skipRecovery()
Defines whether recovery for this message should be skipped.
|
String |
toString() |
boolean |
writeTo(ByteBuffer buf,
MessageWriter writer)
Writes this message to provided byte buffer.
|
setReader
public TcpCommunicationSpi.RecoveryLastReceivedMessage()
MessageAdapter
.public TcpCommunicationSpi.RecoveryLastReceivedMessage(long rcvCnt)
rcvCnt
- Number of received messages.public long received()
public boolean writeTo(ByteBuffer buf, MessageWriter writer)
writeTo
in class MessageAdapter
buf
- Byte buffer.writer
- Writer.public boolean readFrom(ByteBuffer buf)
readFrom
in class MessageAdapter
buf
- Byte buffer.public byte directType()
directType
in class MessageAdapter
public boolean skipRecovery()
skipRecovery
in class MessageAdapter
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 16 2015