Interface MessageReader
-
public interface MessageReaderCommunication message reader.Allows to customize the binary format of communication messages.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidafterInnerMessageRead(boolean finished)Callback called after inner message is read.booleanafterMessageRead(Class<? extends Message> msgCls)Callback that must be invoked by a message implementation after message body finished decoding.voidbeforeInnerMessageRead()Callback called before inner message is read.booleanbeforeMessageRead()Callback that must be invoked by a message implementation before message body started decoding.voidincrementState()Increments read state.booleanisLastRead()Tells whether last invocation of any ofreadXXX(...)methods has fully written the value.org.apache.ignite.internal.processors.affinity.AffinityTopologyVersionreadAffinityTopologyVersion(String name)ReadsAffinityTopologyVersion.BitSetreadBitSet(String name)ReadsBitSet.booleanreadBoolean(String name)Readsbooleanvalue.boolean[]readBooleanArray(String name)Readsbooleanarray.bytereadByte(String name)Readsbytevalue.byte[]readByteArray(String name)Readsbytearray.charreadChar(String name)Readscharvalue.char[]readCharArray(String name)Readschararray.<C extends Collection<?>>
CreadCollection(String name, MessageCollectionItemType itemType)Reads collection.doublereadDouble(String name)Readsdoublevalue.double[]readDoubleArray(String name)Readsdoublearray.floatreadFloat(String name)Readsfloatvalue.float[]readFloatArray(String name)Readsfloatarray.IgniteUuidreadIgniteUuid(String name)ReadsIgniteUuid.intreadInt(String name)Readsintvalue.intreadInt(String name, int dflt)Readsintvalue.int[]readIntArray(String name)Readsintarray.longreadLong(String name)Readslongvalue.long[]readLongArray(String name)Readslongarray.<M extends Map<?,?>>
MreadMap(String name, MessageCollectionItemType keyType, MessageCollectionItemType valType, boolean linked)Reads map.<T extends Message>
TreadMessage(String name)Reads nested message.<T> T[]readObjectArray(String name, MessageCollectionItemType itemType, Class<T> itemCls)Reads array of objects.shortreadShort(String name)Readsshortvalue.short[]readShortArray(String name)Readsshortarray.StringreadString(String name)ReadsString.UUIDreadUuid(String name)ReadsUUID.voidreset()Resets this reader.voidsetBuffer(ByteBuffer buf)Sets but buffer to read from.voidsetCurrentReadClass(Class<? extends Message> msgCls)Sets type of message currently read.intstate()Gets current read state.
-
-
-
Method Detail
-
setBuffer
void setBuffer(ByteBuffer buf)
Sets but buffer to read from.- Parameters:
buf- Byte buffer.
-
setCurrentReadClass
void setCurrentReadClass(Class<? extends Message> msgCls)
Sets type of message currently read.- Parameters:
msgCls- Message type.
-
beforeMessageRead
boolean beforeMessageRead()
Callback that must be invoked by a message implementation before message body started decoding.- Returns:
Trueif reading can proceed,falseotherwise.
-
afterMessageRead
boolean afterMessageRead(Class<? extends Message> msgCls)
Callback that must be invoked by a message implementation after message body finished decoding.- Parameters:
msgCls- Message class finishing read stage.- Returns:
Trueif reading can proceed,falseotherwise.
-
readByte
byte readByte(String name)
Readsbytevalue.- Parameters:
name- Field name.- Returns:
bytevalue.
-
readShort
short readShort(String name)
Readsshortvalue.- Parameters:
name- Field name.- Returns:
shortvalue.
-
readInt
int readInt(String name)
Readsintvalue.- Parameters:
name- Field name.- Returns:
intvalue.
-
readInt
int readInt(String name, int dflt)
Readsintvalue.- Parameters:
name- Field name.dflt- Default value if field not found.- Returns:
intvalue.
-
readLong
long readLong(String name)
Readslongvalue.- Parameters:
name- Field name.- Returns:
longvalue.
-
readFloat
float readFloat(String name)
Readsfloatvalue.- Parameters:
name- Field name.- Returns:
floatvalue.
-
readDouble
double readDouble(String name)
Readsdoublevalue.- Parameters:
name- Field name.- Returns:
doublevalue.
-
readChar
char readChar(String name)
Readscharvalue.- Parameters:
name- Field name.- Returns:
charvalue.
-
readBoolean
boolean readBoolean(String name)
Readsbooleanvalue.- Parameters:
name- Field name.- Returns:
booleanvalue.
-
readByteArray
byte[] readByteArray(String name)
Readsbytearray.- Parameters:
name- Field name.- Returns:
bytearray.
-
readShortArray
short[] readShortArray(String name)
Readsshortarray.- Parameters:
name- Field name.- Returns:
shortarray.
-
readIntArray
int[] readIntArray(String name)
Readsintarray.- Parameters:
name- Field name.- Returns:
intarray.
-
readLongArray
long[] readLongArray(String name)
Readslongarray.- Parameters:
name- Field name.- Returns:
longarray.
-
readFloatArray
float[] readFloatArray(String name)
Readsfloatarray.- Parameters:
name- Field name.- Returns:
floatarray.
-
readDoubleArray
double[] readDoubleArray(String name)
Readsdoublearray.- Parameters:
name- Field name.- Returns:
doublearray.
-
readCharArray
char[] readCharArray(String name)
Readschararray.- Parameters:
name- Field name.- Returns:
chararray.
-
readBooleanArray
boolean[] readBooleanArray(String name)
Readsbooleanarray.- Parameters:
name- Field name.- Returns:
booleanarray.
-
readString
String readString(String name)
ReadsString.- Parameters:
name- Field name.- Returns:
String.
-
readBitSet
BitSet readBitSet(String name)
ReadsBitSet.- Parameters:
name- Field name.- Returns:
BitSet.
-
readIgniteUuid
IgniteUuid readIgniteUuid(String name)
ReadsIgniteUuid.- Parameters:
name- Field name.- Returns:
IgniteUuid.
-
readAffinityTopologyVersion
org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion readAffinityTopologyVersion(String name)
ReadsAffinityTopologyVersion.- Parameters:
name- Field name.- Returns:
AffinityTopologyVersion.
-
readMessage
<T extends Message> T readMessage(String name)
Reads nested message.- Type Parameters:
T- Type of the message.- Parameters:
name- Field name.- Returns:
- Message.
-
readObjectArray
<T> T[] readObjectArray(String name, MessageCollectionItemType itemType, Class<T> itemCls)
Reads array of objects.- Type Parameters:
T- Type of the red object .- Parameters:
name- Field name.itemType- Array component type.itemCls- Array component class.- Returns:
- Array of objects.
-
readCollection
<C extends Collection<?>> C readCollection(String name, MessageCollectionItemType itemType)
Reads collection.- Type Parameters:
C- Type of the red collection.- Parameters:
name- Field name.itemType- Collection item type.- Returns:
- Collection.
-
readMap
<M extends Map<?,?>> M readMap(String name, MessageCollectionItemType keyType, MessageCollectionItemType valType, boolean linked)
Reads map.- Type Parameters:
M- Type of the red map.- Parameters:
name- Field name.keyType- Map key type.valType- Map value type.linked- WhetherLinkedHashMapshould be created.- Returns:
- Map.
-
isLastRead
boolean isLastRead()
Tells whether last invocation of any ofreadXXX(...)methods has fully written the value.Falseis returned if there were not enough remaining bytes in byte buffer.- Returns:
- Whether las value was fully read.
-
state
int state()
Gets current read state.- Returns:
- Read state.
-
incrementState
void incrementState()
Increments read state.
-
beforeInnerMessageRead
void beforeInnerMessageRead()
Callback called before inner message is read.
-
afterInnerMessageRead
void afterInnerMessageRead(boolean finished)
Callback called after inner message is read.- Parameters:
finished- Whether message was fully read.
-
reset
void reset()
Resets this reader.
-
-