Package deltix.qsrv.hf.tickdb.pub.query

Class MessageInfoBuffer

java.lang.Object

deltix.qsrv.hf.tickdb.pub.query.MessageInfoBuffer

All Implemented Interfaces:

MessageInfo, TypedMessageSource

public final class MessageInfoBuffer
extends java.lang.Object
implements MessageInfo

Efficiently buffers all information contained in a MessageInfo instance.

Field Summary

Fields

Modifier and Type	Field	Description
int	currentEntityIdx
deltix.qsrv.hf.pub.InstrumentMessage	currentMessage
TickStream	currentStream
int	currentStreamIdx
RecordClassDescriptor	currentType
int	currentTypeIdx

Constructor Summary

Constructors

Constructor	Description
MessageInfoBuffer()

Method Summary

Modifier and Type	Method	Description
void	copyFrom(MessageInfo delegate)
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.
RecordClassDescriptor	getCurrentType()	Returns the type of the current message.
int	getCurrentTypeIndex()	Returns the type index of the current message.
deltix.qsrv.hf.pub.InstrumentMessage	getMessage()	Returns the current message.
void	setMessageNoCopy(deltix.qsrv.hf.pub.InstrumentMessage msg)
void	setUpNoCopy(MessageInfo delegate, deltix.qsrv.hf.pub.InstrumentMessage msg)

Methods inherited from class java.lang.Object

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

Field Detail

currentMessage

public deltix.qsrv.hf.pub.InstrumentMessage currentMessage

currentTypeIdx

public int currentTypeIdx

currentType

public RecordClassDescriptor currentType

currentStreamIdx

public int currentStreamIdx

currentStream

public TickStream currentStream

currentEntityIdx

public int currentEntityIdx

Constructor Detail

MessageInfoBuffer

public MessageInfoBuffer()

Method Detail

setMessageNoCopy

public void setMessageNoCopy(deltix.qsrv.hf.pub.InstrumentMessage msg)

setUpNoCopy

public void setUpNoCopy(MessageInfo delegate,
                        deltix.qsrv.hf.pub.InstrumentMessage msg)

copyFrom

public void copyFrom(MessageInfo delegate)

getMessage

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

Description copied from interface: MessageInfo

Returns the current message.

Specified by:

getMessage in interface MessageInfo

getCurrentTypeIndex

public int getCurrentTypeIndex()

Description copied from interface: TypedMessageSource

Returns the type index of the current message.

Specified by:

getCurrentTypeIndex in interface TypedMessageSource

Returns:

The current message type index.

getCurrentType

public RecordClassDescriptor getCurrentType()

Description copied from interface: TypedMessageSource

Returns the type of the current message.

Specified by:

getCurrentType in interface TypedMessageSource

Returns:

The current message type.

getCurrentStreamKey

public java.lang.String getCurrentStreamKey()

Description copied from interface: MessageInfo

Return the key of the stream that is the source of the current message.

Specified by:

getCurrentStreamKey in interface MessageInfo

Returns:

The source stream key.

getCurrentStreamIndex

public int getCurrentStreamIndex()

Description copied from interface: MessageInfo

Return the index of the stream that is the source of the current message.

Specified by:

getCurrentStreamIndex in interface MessageInfo

Returns:

The current message source stream's index.

getCurrentStream

public TickStream getCurrentStream()

Description copied from interface: MessageInfo

Return the current stream instance, unless it has been removed, in which case null is returned.

Specified by:

getCurrentStream in interface MessageInfo

getCurrentEntityIndex

public int getCurrentEntityIndex()

Description copied from interface: MessageInfo

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.

Specified by:

getCurrentEntityIndex in interface MessageInfo

See Also:

EntitySubscriptionController