AbstractMessageReader |
Base class for reading InstrumentMessage from persistent data storage
|
AbstractMessageWriter |
Base class for InstrumentMessages serialization to persistent data storage
|
BufferedStreamSorterEx<T extends deltix.qsrv.hf.pub.InstrumentMessage> |
|
DXDataReader |
|
DXDataWriter |
|
LimitedInstrumentMessageSource |
MessageSource that simulates end-of-stream at given timestamp
|
LimitedMessageSource |
MessageSource that simulates end-of-stream at given timestamp
|
MessageFileHeader |
Message file metadata container.
|
MessageProcessor |
Helper utility class for comparing RecordClassDescriptors.
|
MessageReader2 |
|
MessageSorter |
|
MessageWriter |
Deprecated. |
MessageWriter2 |
This class is thread-unsafe.
|
PermanentlyUnavailableMessageSource |
Always throws UnavailableResourceException on next();
|
Protocol |
|
SortingMessageSource<T extends deltix.data.stream.TimeStampedMessage> |
This class reorders messages coming from nested message source (in time order).
|
SpacesProtocol |
|