Package deltix.qsrv.hf.stream

Class PermanentlyUnavailableMessageSource

java.lang.Object

deltix.qsrv.hf.stream.PermanentlyUnavailableMessageSource

All Implemented Interfaces:

deltix.data.stream.MessageSource<deltix.qsrv.hf.pub.InstrumentMessage>, RealTimeMessageSource<deltix.qsrv.hf.pub.InstrumentMessage>, deltix.util.concurrent.AbstractCursor, deltix.util.concurrent.IntermittentlyAvailableResource, deltix.util.lang.Disposable, java.io.Closeable, java.lang.AutoCloseable

public class PermanentlyUnavailableMessageSource
extends java.lang.Object
implements RealTimeMessageSource<deltix.qsrv.hf.pub.InstrumentMessage>, deltix.util.concurrent.IntermittentlyAvailableResource

Always throws UnavailableResourceException on next();

Constructor Summary

Constructors

Constructor	Description
PermanentlyUnavailableMessageSource()

Method Summary

Modifier and Type	Method	Description
void	close()
deltix.qsrv.hf.pub.InstrumentMessage	getMessage()
boolean	isAtEnd()
boolean	isRealTime()
boolean	next()
boolean	realTimeAvailable()
void	setAvailabilityListener(java.lang.Runnable listener)

Methods inherited from class java.lang.Object

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

Constructor Detail

PermanentlyUnavailableMessageSource

public PermanentlyUnavailableMessageSource()

Method Detail

setAvailabilityListener

public void setAvailabilityListener(java.lang.Runnable listener)

Specified by:

setAvailabilityListener in interface deltix.util.concurrent.IntermittentlyAvailableResource

getMessage

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

Specified by:

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

next

public boolean next()

Specified by:

next in interface deltix.util.concurrent.AbstractCursor

isAtEnd

public boolean isAtEnd()

Specified by:

isAtEnd in interface deltix.util.concurrent.AbstractCursor

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface deltix.util.lang.Disposable

isRealTime

public boolean isRealTime()

Specified by:

isRealTime in interface RealTimeMessageSource<deltix.qsrv.hf.pub.InstrumentMessage>

Returns:

true if this source already switched from historical to real-time data portion

realTimeAvailable

public boolean realTimeAvailable()

Specified by:

realTimeAvailable in interface RealTimeMessageSource<deltix.qsrv.hf.pub.InstrumentMessage>

Returns:

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