Package deltix.qsrv.hf.tickdb.pub
Interface TickLoader<T extends deltix.qsrv.hf.pub.InstrumentMessageInfo>
-
- All Superinterfaces:
java.lang.AutoCloseable,java.io.Closeable,deltix.util.lang.Disposable,java.io.Flushable,deltix.data.stream.MessageChannel<T>
- All Known Implementing Classes:
FilterTickLoader,TimestampIgnoringTickLoader
public interface TickLoader<T extends deltix.qsrv.hf.pub.InstrumentMessageInfo> extends deltix.data.stream.MessageChannel<T>, java.io.Flushable
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidaddEventListener(LoadingErrorListener listener)voidaddSubscriptionListener(SubscriptionChangeListener listener)WritableTickStreamgetTargetStream()voidremoveEventListener(LoadingErrorListener listener)voidremoveSubscriptionListener(SubscriptionChangeListener listener)voidremoveUnique(T msg)
-
-
-
Method Detail
-
getTargetStream
WritableTickStream getTargetStream()
-
addEventListener
void addEventListener(LoadingErrorListener listener)
-
removeEventListener
void removeEventListener(LoadingErrorListener listener)
-
addSubscriptionListener
void addSubscriptionListener(SubscriptionChangeListener listener)
-
removeSubscriptionListener
void removeSubscriptionListener(SubscriptionChangeListener listener)
-
removeUnique
void removeUnique(T msg)
-
-