Package deltix.qsrv.hf.stream

Class AbstractMessageWriter

java.lang.Object

deltix.qsrv.hf.stream.AbstractMessageWriter

Direct Known Subclasses:

DXDataWriter, MessageWriter2

public class AbstractMessageWriter
extends java.lang.Object

Base class for InstrumentMessages serialization to persistent data storage

Field Summary

Fields

Modifier and Type	Field	Description
protected java.lang.Class<?>[]	classes
protected FixedBoundEncoder[]	encoders
protected int	numTypes
protected RecordClassDescriptor[]	types

Constructor Summary

Constructors

Constructor	Description
AbstractMessageWriter()

Method Summary

Modifier and Type	Method	Description
protected int	addNew(RecordClassDescriptor type, java.lang.Class<?> cls, FixedBoundEncoder encoder)
protected void	encode(deltix.qsrv.hf.pub.InstrumentMessage msg, deltix.util.memory.MemoryDataOutput buffer)
protected int	getTypeIndex(RecordClassDescriptor type)
protected int	getTypeIndex(java.lang.Class<?> cls)
RecordClassDescriptor[]	getTypes()
protected void	set(int index, RecordClassDescriptor rcd, java.lang.Class<?> cls, FixedBoundEncoder encoder)
protected static void	writeHeader(java.io.OutputStream out, deltix.util.time.Interval periodicity, RecordClassDescriptor[] types)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

numTypes

protected int numTypes

classes

protected final java.lang.Class<?>[] classes

types

protected final RecordClassDescriptor[] types

encoders

protected final FixedBoundEncoder[] encoders

Constructor Detail

AbstractMessageWriter

public AbstractMessageWriter()

Method Detail

getTypes

public RecordClassDescriptor[] getTypes()

addNew

protected int addNew(RecordClassDescriptor type,
                     java.lang.Class<?> cls,
                     FixedBoundEncoder encoder)

set

protected void set(int index,
                   RecordClassDescriptor rcd,
                   java.lang.Class<?> cls,
                   FixedBoundEncoder encoder)

getTypeIndex

protected int getTypeIndex(RecordClassDescriptor type)

getTypeIndex

protected int getTypeIndex(java.lang.Class<?> cls)

encode

protected void encode(deltix.qsrv.hf.pub.InstrumentMessage msg,
                      deltix.util.memory.MemoryDataOutput buffer)
               throws java.io.IOException

Throws:

java.io.IOException

writeHeader

protected static void writeHeader(java.io.OutputStream out,
                                  deltix.util.time.Interval periodicity,
                                  RecordClassDescriptor[] types)
                           throws java.io.IOException

Throws:

java.io.IOException