Package deltix.qsrv.hf.tickdb.pub.query
Interface MessageInfo
-
- All Superinterfaces:
TypedMessageSource
- All Known Subinterfaces:
InstrumentMessageSource
,TickCursor
,UniqueQuoteCursor
- All Known Implementing Classes:
InstrumentMessageSourceAdapter
,LimitedInstrumentMessageSource
,MessageInfoBuffer
,SubscriptionManagerWrapper
,TickCursorAdapter
,TickCursorClientAeron
,TickCursorClientAeronMulticast
public interface MessageInfo extends TypedMessageSource
Supplies an InstrumentMessage as well as information about its source stream and RecordClassDescriptor.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description int
getCurrentEntityIndex()
Return a small number identifying the returned entity.TickStream
getCurrentStream()
Return the current stream instance, unless it has been removed, in which case null is returned.int
getCurrentStreamIndex()
Return the index of the stream that is the source of the current message.java.lang.String
getCurrentStreamKey()
Return the key of the stream that is the source of the current message.deltix.qsrv.hf.pub.InstrumentMessage
getMessage()
Returns the current message.-
Methods inherited from interface deltix.qsrv.hf.tickdb.pub.query.TypedMessageSource
getCurrentType, getCurrentTypeIndex
-
-
-
-
Method Detail
-
getMessage
deltix.qsrv.hf.pub.InstrumentMessage getMessage()
Returns the current message.
-
getCurrentStreamIndex
int getCurrentStreamIndex()
Return the index of the stream that is the source of the current message.- Returns:
- The current message source stream's index.
-
getCurrentStreamKey
java.lang.String getCurrentStreamKey()
Return the key of the stream that is the source of the current message.- Returns:
- The source stream key.
-
getCurrentStream
TickStream getCurrentStream()
Return the current stream instance, unless it has been removed, in which case null is returned.
-
getCurrentEntityIndex
int getCurrentEntityIndex()
Return a small number identifying the returned entity. This number is unique throughout the life of the message source. Removing entities from subscription does not create reusable holes in the "space" of entity indexes.- See Also:
EntitySubscriptionController
-
-