Class TimestampIgnoringTickLoader

  • All Implemented Interfaces:
    deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>, TickLoader<deltix.qsrv.hf.pub.InstrumentMessage>, deltix.util.lang.Disposable, java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable

    public class TimestampIgnoringTickLoader
    extends FilterTickLoader<deltix.qsrv.hf.pub.InstrumentMessage>
    Forces server-side setting of the timestamp of all messages passing through this loader, by resetting the timestamp to TimeConstants.TIMESTAMP_UNKNOWN
    • Constructor Detail

      • TimestampIgnoringTickLoader

        public TimestampIgnoringTickLoader​(TickLoader<deltix.qsrv.hf.pub.InstrumentMessage> delegate)
    • Method Detail

      • send

        public void send​(deltix.qsrv.hf.pub.InstrumentMessage msg)
        Specified by:
        send in interface deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>
        Overrides:
        send in class FilterTickLoader<deltix.qsrv.hf.pub.InstrumentMessage>