RealTimeMessageSource (java 5.5.18-SNAPSHOT API)

All Superinterfaces:

deltix.util.concurrent.AbstractCursor, java.lang.AutoCloseable, java.io.Closeable, deltix.util.lang.Disposable, deltix.data.stream.MessageSource<T>

All Known Subinterfaces:

InstrumentMessageSource, TickCursor

All Known Implementing Classes:

IAMessageSourceMultiplexer, InstrumentMessageSourceAdapter, LimitedInstrumentMessageSource, MessageSourceMultiplexer, PermanentlyUnavailableMessageSource, SubscriptionManagerWrapper, TickCursorAdapter, TickCursorClientAeron, TickCursorClientAeronMulticast
```
public interface RealTimeMessageSource<T>
extends deltix.data.stream.MessageSource<T>
```
Message source that has indication of switching in real-time mode from historical. Message source will emit RealTimeStartMessage when when realTimeAvailable() is true and no ACTUAL data available at this moment: for DURABLE streams - data files does not contain unread data, for TRANSIENT streams - message buffer is exhausted. After invoking "reset()" RealTimeMessageSource will produce at most one RealTimeStartMessage.

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  boolean isRealTime()
  
  boolean realTimeAvailable()
  - Methods inherited from interface deltix.util.concurrent.AbstractCursor
    isAtEnd, next
  - Methods inherited from interface deltix.util.lang.Disposable
    close
  - Methods inherited from interface deltix.data.stream.MessageSource
    getMessage

- Method Detail
  - isRealTime
```
boolean isRealTime()
```
    Returns:
    
    true if this source already switched from historical to real-time data portion
  - realTimeAvailable
```
boolean realTimeAvailable()
```
    Returns:
    
    true if source can be switched in real-time. When realtime mode is available client can use method isRealTime() ()} to detect switch from historical to real-time portion of data. Also in this mode client will receive special message RealTimeStartMessage .