Package deltix.data.stream

Class IAMessageSourceMultiplexer<T extends deltix.data.stream.TimeStampedMessage>

java.lang.Object

deltix.data.stream.MessageSourceMultiplexer<T>

deltix.data.stream.IAMessageSourceMultiplexer<T>

All Implemented Interfaces:

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

public class IAMessageSourceMultiplexer<T extends deltix.data.stream.TimeStampedMessage>
extends MessageSourceMultiplexer<T>
implements deltix.util.concurrent.IntermittentlyAvailableCursor

Nested Class Summary

Nested classes/interfaces inherited from class deltix.data.stream.MessageSourceMultiplexer

MessageSourceMultiplexer.ExceptionHandler

Field Summary

Fields inherited from class deltix.data.stream.MessageSourceMultiplexer

asyncException, checkSources, currentMessage, currentSource, currentTime, emptySources, isAtBeginning, isRealTime, queue, realtimeMessage, realTimeNotification, realTimeStarted

Constructor Summary

Constructors

Constructor	Description
IAMessageSourceMultiplexer()
IAMessageSourceMultiplexer(boolean ascending, boolean realTimeNotification)
IAMessageSourceMultiplexer(boolean ascending, boolean realTimeNotification, java.util.Comparator<T> c)

Method Summary

Modifier and Type	Method	Description
protected deltix.util.concurrent.NextResult	moveNext(deltix.data.stream.MessageSource<T> feed, boolean addEmpty)
deltix.util.concurrent.NextResult	nextIfAvailable()

Methods inherited from class deltix.data.stream.MessageSourceMultiplexer

add, add, addEmptySource, addSync, advanceRealTime, clearSources, close, closeAndRemove, closeFeed, createRealTimeMessage, getAllowLateOutOfOrder, getCurrentSource, getCurrentTime, getExceptionHandler, getMessage, handleException, invalidateRealTimeState, isAtEnd, isClosed, isEmpty, isLive, isRealTime, isRealTimeMessage, isRealTimeStarted, next, nextAvailable, processEmptyQueue, realTimeAvailable, remove, reset, reset, reset, reset, reset, sendRealTimeMessage, setAllowLateOutOfOrder, setAvailabilityListener, setException, setExceptionHandler, setLive, syncGetCurrentSource, syncGetCurrentTime, syncGetMessage, syncIsAtEnd, syncIsClosed, syncNext, syncNext

Methods inherited from class java.lang.Object

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

Methods inherited from interface deltix.util.concurrent.AbstractCursor

isAtEnd, next

Methods inherited from interface deltix.util.lang.Disposable

close

Constructor Detail

IAMessageSourceMultiplexer

public IAMessageSourceMultiplexer()

IAMessageSourceMultiplexer

public IAMessageSourceMultiplexer(boolean ascending,
                                  boolean realTimeNotification,
                                  java.util.Comparator<T> c)

IAMessageSourceMultiplexer

public IAMessageSourceMultiplexer(boolean ascending,
                                  boolean realTimeNotification)

Method Detail

nextIfAvailable

public deltix.util.concurrent.NextResult nextIfAvailable()

Specified by:

nextIfAvailable in interface deltix.util.concurrent.IntermittentlyAvailableCursor

moveNext

protected deltix.util.concurrent.NextResult moveNext(deltix.data.stream.MessageSource<T> feed,
                                                     boolean addEmpty)

Overrides:

moveNext in class MessageSourceMultiplexer<T extends deltix.data.stream.TimeStampedMessage>