Interface MessageReader
- 
 public interface MessageReaderCommunication message reader.Allows to customize the binary format of communication messages. 
- 
- 
Method SummaryAll 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- 
setBuffervoid setBuffer(ByteBuffer buf) Sets but buffer to read from.- Parameters:
- buf- Byte buffer.
 
 - 
setCurrentReadClassvoid setCurrentReadClass(Class<? extends Message> msgCls) Sets type of message currently read.- Parameters:
- msgCls- Message type.
 
 - 
beforeMessageReadboolean beforeMessageRead() Callback that must be invoked by a message implementation before message body started decoding.- Returns:
- Trueif reading can proceed,- falseotherwise.
 
 - 
afterMessageReadboolean 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.
 
 - 
readBytebyte readByte(String name) Readsbytevalue.- Parameters:
- name- Field name.
- Returns:
- bytevalue.
 
 - 
readShortshort readShort(String name) Readsshortvalue.- Parameters:
- name- Field name.
- Returns:
- shortvalue.
 
 - 
readIntint readInt(String name) Readsintvalue.- Parameters:
- name- Field name.
- Returns:
- intvalue.
 
 - 
readIntint readInt(String name, int dflt) Readsintvalue.- Parameters:
- name- Field name.
- dflt- Default value if field not found.
- Returns:
- intvalue.
 
 - 
readLonglong readLong(String name) Readslongvalue.- Parameters:
- name- Field name.
- Returns:
- longvalue.
 
 - 
readFloatfloat readFloat(String name) Readsfloatvalue.- Parameters:
- name- Field name.
- Returns:
- floatvalue.
 
 - 
readDoubledouble readDouble(String name) Readsdoublevalue.- Parameters:
- name- Field name.
- Returns:
- doublevalue.
 
 - 
readCharchar readChar(String name) Readscharvalue.- Parameters:
- name- Field name.
- Returns:
- charvalue.
 
 - 
readBooleanboolean readBoolean(String name) Readsbooleanvalue.- Parameters:
- name- Field name.
- Returns:
- booleanvalue.
 
 - 
readByteArraybyte[] readByteArray(String name) Readsbytearray.- Parameters:
- name- Field name.
- Returns:
- bytearray.
 
 - 
readShortArrayshort[] readShortArray(String name) Readsshortarray.- Parameters:
- name- Field name.
- Returns:
- shortarray.
 
 - 
readIntArrayint[] readIntArray(String name) Readsintarray.- Parameters:
- name- Field name.
- Returns:
- intarray.
 
 - 
readLongArraylong[] readLongArray(String name) Readslongarray.- Parameters:
- name- Field name.
- Returns:
- longarray.
 
 - 
readFloatArrayfloat[] readFloatArray(String name) Readsfloatarray.- Parameters:
- name- Field name.
- Returns:
- floatarray.
 
 - 
readDoubleArraydouble[] readDoubleArray(String name) Readsdoublearray.- Parameters:
- name- Field name.
- Returns:
- doublearray.
 
 - 
readCharArraychar[] readCharArray(String name) Readschararray.- Parameters:
- name- Field name.
- Returns:
- chararray.
 
 - 
readBooleanArrayboolean[] readBooleanArray(String name) Readsbooleanarray.- Parameters:
- name- Field name.
- Returns:
- booleanarray.
 
 - 
readStringString readString(String name) ReadsString.- Parameters:
- name- Field name.
- Returns:
- String.
 
 - 
readBitSetBitSet readBitSet(String name) ReadsBitSet.- Parameters:
- name- Field name.
- Returns:
- BitSet.
 
 - 
readIgniteUuidIgniteUuid readIgniteUuid(String name) ReadsIgniteUuid.- Parameters:
- name- Field name.
- Returns:
- IgniteUuid.
 
 - 
readAffinityTopologyVersionorg.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- Whether- LinkedHashMapshould be created.
- Returns:
- Map.
 
 - 
isLastReadboolean 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.
 
 - 
stateint state() Gets current read state.- Returns:
- Read state.
 
 - 
incrementStatevoid incrementState() Increments read state.
 - 
beforeInnerMessageReadvoid beforeInnerMessageRead() Callback called before inner message is read.
 - 
afterInnerMessageReadvoid afterInnerMessageRead(boolean finished) Callback called after inner message is read.- Parameters:
- finished- Whether message was fully read.
 
 - 
resetvoid reset() Resets this reader.
 
- 
 
-