Package deltix.qsrv.hf.stream

Class DXDataWriter

java.lang.Object

deltix.qsrv.hf.stream.AbstractMessageWriter

deltix.qsrv.hf.stream.DXDataWriter

All Implemented Interfaces:

deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>, deltix.util.lang.Disposable, java.io.Closeable, java.lang.AutoCloseable

public class DXDataWriter
extends AbstractMessageWriter
implements deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>

Field Summary

Fields

Modifier and Type	Field	Description
protected deltix.util.memory.MemoryDataOutput	buffer

Fields inherited from class deltix.qsrv.hf.stream.AbstractMessageWriter

classes, encoders, numTypes, types

Constructor Summary

Constructors

Constructor	Description
DXDataWriter(java.io.File file)

Method Summary

Modifier and Type	Method	Description
void	close()
long	count()
void	endBlock()
void	send(deltix.qsrv.hf.pub.InstrumentMessage msg)
void	startBlock(java.lang.String key)
void	startBlock(java.lang.String key, RecordClassDescriptor... descriptors)

Methods inherited from class deltix.qsrv.hf.stream.AbstractMessageWriter

addNew, encode, getTypeIndex, getTypeIndex, getTypes, set, writeHeader

Methods inherited from class java.lang.Object

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

Field Detail

buffer

protected final deltix.util.memory.MemoryDataOutput buffer

Constructor Detail

DXDataWriter

public DXDataWriter(java.io.File file)
             throws java.io.IOException

Throws:

java.io.IOException

Method Detail

startBlock

public void startBlock(java.lang.String key)
                throws java.io.IOException

Throws:

java.io.IOException

startBlock

public void startBlock(java.lang.String key,
                       RecordClassDescriptor... descriptors)
                throws java.io.IOException

Throws:

java.io.IOException

endBlock

public void endBlock()
              throws java.io.IOException

Throws:

java.io.IOException

send

public void send(deltix.qsrv.hf.pub.InstrumentMessage msg)

Specified by:

send in interface deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>

count

public long count()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface deltix.util.lang.Disposable