Package deltix.qsrv.hf.stream

Class LimitedInstrumentMessageSource

java.lang.Object

deltix.qsrv.hf.tickdb.pub.MessageSourceAdapter<deltix.qsrv.hf.pub.InstrumentMessage>

deltix.qsrv.hf.tickdb.pub.InstrumentMessageSourceAdapter

deltix.qsrv.hf.stream.LimitedInstrumentMessageSource

All Implemented Interfaces:

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

public class LimitedInstrumentMessageSource
extends InstrumentMessageSourceAdapter
implements deltix.util.concurrent.IntermittentlyAvailableCursor

MessageSource that simulates end-of-stream at given timestamp

Constructor Summary

Constructors

Constructor	Description
LimitedInstrumentMessageSource(InstrumentMessageSource delegate, long endTime)

Method Summary

Modifier and Type	Method	Description
deltix.qsrv.hf.pub.InstrumentMessage	getMessage()	Returns the current message.
boolean	isAtEnd()
boolean	next()
deltix.util.concurrent.NextResult	nextIfAvailable()

Methods inherited from class deltix.qsrv.hf.tickdb.pub.InstrumentMessageSourceAdapter

add, add, addEntities, addEntity, addStream, addSymbol, addSymbols, addSymbols, addTypes, clearAllEntities, clearAllSymbols, close, getCurrentEntityIndex, getCurrentStream, getCurrentStreamIndex, getCurrentStreamKey, getCurrentType, getCurrentTypeIndex, getDelegate, isClosed, isRealTime, realTimeAvailable, remove, remove, removeAllStreams, removeEntities, removeEntity, removeStream, removeSymbol, removeSymbols, removeSymbols, removeTypes, reset, setAvailabilityListener, setTimeForNewSubscriptions, setTypes, subscribeToAllEntities, subscribeToAllSymbols, subscribeToAllTypes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface deltix.util.lang.Disposable

close

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

addEntities, removeEntities

Constructor Detail

LimitedInstrumentMessageSource

public LimitedInstrumentMessageSource(InstrumentMessageSource delegate,
                                      long endTime)

Method Detail

getMessage

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

Description copied from interface: MessageInfo

Returns the current message.

Specified by:

getMessage in interface InstrumentMessageSource

Specified by:

getMessage in interface MessageInfo

Specified by:

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

Overrides:

getMessage in class InstrumentMessageSourceAdapter

isAtEnd

public boolean isAtEnd()

Specified by:

isAtEnd in interface deltix.util.concurrent.AbstractCursor

Overrides:

isAtEnd in class InstrumentMessageSourceAdapter

next

public boolean next()

Specified by:

next in interface deltix.util.concurrent.AbstractCursor

Overrides:

next in class InstrumentMessageSourceAdapter

nextIfAvailable

public deltix.util.concurrent.NextResult nextIfAvailable()

Specified by:

nextIfAvailable in interface deltix.util.concurrent.IntermittentlyAvailableCursor