Package deltix.qsrv.hf.tickdb.pub.query

Interface InstrumentMessageSource

All Superinterfaces:

deltix.util.concurrent.AbstractCursor, java.lang.AutoCloseable, java.io.Closeable, deltix.util.lang.Disposable, EntityAndTypeSubscriptionController, EntitySubscriptionController, deltix.util.concurrent.IntermittentlyAvailableResource, MessageInfo, deltix.data.stream.MessageSource<deltix.qsrv.hf.pub.InstrumentMessage>, RealTimeMessageSource<deltix.qsrv.hf.pub.InstrumentMessage>, StreamSubscriptionController, SubscriptionController, SymbolAndTypeSubscriptionController, SymbolSubscriptionController, TimeController, TypedMessageSource, TypeSubscriptionController

All Known Subinterfaces:

TickCursor

All Known Implementing Classes:

InstrumentMessageSourceAdapter, LimitedInstrumentMessageSource, SubscriptionManagerWrapper, TickCursorAdapter, TickCursorClientAeron

public interface InstrumentMessageSource
extends deltix.data.stream.MessageSource<deltix.qsrv.hf.pub.InstrumentMessage>, SubscriptionController, MessageInfo, deltix.util.concurrent.IntermittentlyAvailableResource, RealTimeMessageSource<deltix.qsrv.hf.pub.InstrumentMessage>

InstrumentMessageSource instances are subject to the following policies:

1. All read methods (those inherited from MessageInfo and MessageSource, except close ()) must be mutually synchronized by the caller, since it does not make sense to read a cursor from concurrent threads. This is called a Single-Thread Read Policy
2. The read thread will see a consistent picture between the invocations of next ().
3. All remaining methods, including close (), are called control methods, and they may be invoked asynchronously.

Method Summary

Modifier and Type	Method	Description
deltix.qsrv.hf.pub.InstrumentMessage	getMessage()	Returns the current message.
boolean	isClosed()

Methods inherited from interface deltix.util.concurrent.AbstractCursor

isAtEnd, next

Methods inherited from interface deltix.util.lang.Disposable

close

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.EntityAndTypeSubscriptionController

add, remove

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.EntitySubscriptionController

addEntities, addEntities, addEntity, clearAllEntities, removeEntities, removeEntities, removeEntity, subscribeToAllEntities

Methods inherited from interface deltix.util.concurrent.IntermittentlyAvailableResource

setAvailabilityListener

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.MessageInfo

getCurrentEntityIndex, getCurrentStream, getCurrentStreamIndex, getCurrentStreamKey

Methods inherited from interface deltix.data.stream.RealTimeMessageSource

isRealTime, realTimeAvailable

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.StreamSubscriptionController

addStream, removeAllStreams, removeStream

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.SymbolAndTypeSubscriptionController

add, remove

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.SymbolSubscriptionController

addSymbol, addSymbols, addSymbols, clearAllSymbols, removeSymbol, removeSymbols, removeSymbols, subscribeToAllSymbols

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.TimeController

reset, setTimeForNewSubscriptions

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.TypedMessageSource

getCurrentType, getCurrentTypeIndex

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.TypeSubscriptionController

addTypes, removeTypes, setTypes, subscribeToAllTypes

Method Detail

getMessage

deltix.qsrv.hf.pub.InstrumentMessage getMessage()

Description copied from interface: MessageInfo

Returns the current message.

Specified by:

getMessage in interface MessageInfo

Specified by:

getMessage in interface deltix.data.stream.MessageSource<deltix.qsrv.hf.pub.InstrumentMessage>

isClosed

boolean isClosed()