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 void
send(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:
send
in interfacedeltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>
- Overrides:
send
in classFilterTickLoader<deltix.qsrv.hf.pub.InstrumentMessage>
-
-