Package deltix.qsrv.hf.tickdb.pub
Class TimestampIgnoringTickLoader
- java.lang.Object
-
- deltix.qsrv.hf.tickdb.pub.FilterTickLoader<deltix.qsrv.hf.pub.InstrumentMessage>
-
- deltix.qsrv.hf.tickdb.pub.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 toTimeConstants.TIMESTAMP_UNKNOWN
-
-
Constructor Summary
Constructors Constructor Description TimestampIgnoringTickLoader(TickLoader<deltix.qsrv.hf.pub.InstrumentMessage> delegate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidsend(deltix.qsrv.hf.pub.InstrumentMessage msg)-
Methods inherited from class deltix.qsrv.hf.tickdb.pub.FilterTickLoader
addEventListener, addSubscriptionListener, close, flush, getTargetStream, removeEventListener, removeSubscriptionListener, removeUnique, toString
-
-
-
-
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:
sendin interfacedeltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>- Overrides:
sendin classFilterTickLoader<deltix.qsrv.hf.pub.InstrumentMessage>
-
-