Package deltix.data.stream
-
Interface Summary Interface Description DXChannel<T> MessageDecoder<T> MessageEncoder<T> MessageSender Something that can provide messages to given target channelMessageSourceMultiplexer.ExceptionHandler RealTimeMessageSource<T> Message source that has indication of switching in real-time mode from historical. -
Class Summary Class Description BufferedStreamSorter<T extends deltix.data.stream.TimeStampedMessage> This class enables the sorting of messages in situations when an upper bound can be placed on how badly unsorted the messages are.ChannelPreferences ChannelSettings For the channel create parametersIAMessageSourceMultiplexer<T extends deltix.data.stream.TimeStampedMessage> MessageSourceMultiplexer<T extends deltix.data.stream.TimeStampedMessage> Merge multiple time-sorted message streams into one.MessageSourceMultiplexerFixed<T extends deltix.data.stream.TimeStampedMessage> Alternative implementation ofMessageSourceMultiplexerthat is expected to provide better performance but has a set of limitations: MAIN: it's impossible to change subscription on the fly no realTimeNotification option allowLateOutOfOrder option is static (however this can be changed in cost of minor penalty to performance)PriorityQueue<T> Hand-optimized priority queue of MessageSource objects.SimpleMessageQueue<T> An unbounded queue of arbitrary messages, exposing a MessageChannel and a MessageSource as a way of accessing the queue.TimeMsgComparator TimeMsgSourceComparator -
Exception Summary Exception Description UnknownChannelException