public abstract class MessageAdapter extends Object implements Serializable
Modifier and Type | Class and Description |
---|---|
static class |
MessageAdapter.Type
Enum representing possible types of collection items.
|
Modifier and Type | Field and Description |
---|---|
protected MessageReader |
reader
Message reader.
|
protected int |
readState
Current read state.
|
Constructor and Description |
---|
MessageAdapter() |
Modifier and Type | Method and Description |
---|---|
abstract byte |
directType()
Gets message type.
|
abstract boolean |
readFrom(ByteBuffer buf)
Reads this message from provided byte buffer.
|
void |
setReader(MessageReader reader) |
boolean |
skipRecovery()
Defines whether recovery for this message should be skipped.
|
abstract boolean |
writeTo(ByteBuffer buf,
MessageWriter writer)
Writes this message to provided byte buffer.
|
protected MessageReader reader
protected int readState
public final void setReader(MessageReader reader)
reader
- Message reader.public abstract boolean writeTo(ByteBuffer buf, MessageWriter writer)
buf
- Byte buffer.writer
- Writer.public abstract boolean readFrom(ByteBuffer buf)
buf
- Byte buffer.public abstract byte directType()
public boolean skipRecovery()
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 16 2015