Class OMessageHelper
java.lang.Object
com.orientechnologies.orient.client.remote.message.OMessageHelper
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic byte[]getRecordBytes(ORecord iRecord, ORecordSerializer serializer) readClustersArray(OChannelDataInput network) static Map<UUID,OBonsaiCollectionPointer> readCollectionChanges(OChannelDataInput network) static OIdentifiablereadIdentifiable(OChannelDataInput network, ORecordSerializer serializer) static OPhysicalPosition[]readPhysicalPositions(OChannelDataInput network) static OResultInternalreadResult(OChannelDataInput channel) static ORecordOperationRequestreadTransactionEntry(DataInput iNetwork) static voidwriteClustersArray(OChannelDataOutput channel, ORawPair<String[], int[]> clusters, int protocolVersion) static voidwriteCollectionChanges(OChannelDataOutput channel, Map<UUID, OBonsaiCollectionPointer> changedIds) static voidwriteIdentifiable(OChannelDataOutput channel, OIdentifiable o, ORecordSerializer serializer) static voidwritePhysicalPositions(OChannelDataOutput channel, OPhysicalPosition[] previousPositions) static voidwriteRecord(OChannelDataOutput channel, ORecord iRecord, ORecordSerializer serializer) static voidwriteResult(OResult row, OChannelDataOutput channel, ORecordSerializer recordSerializer) static voidwriteTransactionEntry(DataOutput iNetwork, ORecordOperationRequest txEntry)
-
Constructor Details
-
OMessageHelper
public OMessageHelper()
-
-
Method Details
-
writeIdentifiable
public static void writeIdentifiable(OChannelDataOutput channel, OIdentifiable o, ORecordSerializer serializer) throws IOException - Throws:
IOException
-
writeRecord
public static void writeRecord(OChannelDataOutput channel, ORecord iRecord, ORecordSerializer serializer) throws IOException - Throws:
IOException
-
getRecordBytes
-
readCollectionChanges
public static Map<UUID,OBonsaiCollectionPointer> readCollectionChanges(OChannelDataInput network) throws IOException - Throws:
IOException
-
writeCollectionChanges
public static void writeCollectionChanges(OChannelDataOutput channel, Map<UUID, OBonsaiCollectionPointer> changedIds) throws IOException- Throws:
IOException
-
writePhysicalPositions
public static void writePhysicalPositions(OChannelDataOutput channel, OPhysicalPosition[] previousPositions) throws IOException - Throws:
IOException
-
readPhysicalPositions
public static OPhysicalPosition[] readPhysicalPositions(OChannelDataInput network) throws IOException - Throws:
IOException
-
readClustersArray
public static ORawPair<String[],int[]> readClustersArray(OChannelDataInput network) throws IOException - Throws:
IOException
-
writeClustersArray
public static void writeClustersArray(OChannelDataOutput channel, ORawPair<String[], int[]> clusters, int protocolVersion) throws IOException- Throws:
IOException
-
writeTransactionEntry
public static void writeTransactionEntry(DataOutput iNetwork, ORecordOperationRequest txEntry) throws IOException - Throws:
IOException
-
readTransactionEntry
- Throws:
IOException
-
readIdentifiable
public static OIdentifiable readIdentifiable(OChannelDataInput network, ORecordSerializer serializer) throws IOException - Throws:
IOException
-
writeResult
public static void writeResult(OResult row, OChannelDataOutput channel, ORecordSerializer recordSerializer) throws IOException - Throws:
IOException
-
readResult
- Throws:
IOException
-