RTI.Connext.Queuing.QueueConsumerListener< T > Interface Template Reference

Called when certain events occur in a RTI::Connext::Queuing::QueueConsumer<T> More...

Public Member Functions
void	OnSampleAvailable (QueueConsumer< T > consumer)
	User callback.
void	OnSharedReaderQueueMatched (QueueConsumer< T > consumer, ref SubscriptionMatchedStatus status)
	User callback.

Detailed Description

Called when certain events occur in a RTI::Connext::Queuing::QueueConsumer<T>

A QueueConsumer listener is a way to implement a callback that will be invoked when certain events happen. It is an optional parameter in RTI::Connext::Queuing::QueueConsumerParams<T>.

You can use this listener to receive notification when:

• Samples are available
• There are SharedReaderQueue matching events

See Also

RTI::Connext::Queuing::QueueConsumer<T>::QueueConsumer(ConsumerParams)

Type Constraints

T	:	class
T	:	global
T	:	DDS.ICopyable<T>
T	:	new()

Member Function Documentation

void RTI.Connext.Queuing.QueueConsumerListener< T >.OnSampleAvailable

(

QueueConsumer< T >

consumer

)

User callback.

This callback is invoked whenever the QueueConsumer has received at least one sample. Any operation to get samples i.e. RTI::Connext::Queuing::QueueConsumer<T>::TakeSample(Sample<T>)) can be called within this context.

See Also

DDS::DataReaderListener::on_data_available

void RTI.Connext.Queuing.QueueConsumerListener< T >.OnSharedReaderQueueMatched	(	QueueConsumer< T >	consumer,
		ref SubscriptionMatchedStatus	status
	)

User callback.

This callback is invoked whenever a new SharedReaderQueue hosted by Queuing Service has matched the QueueConsumer, or if an existing matching SharedReaderQueue is disposed.

See Also

DDS::SubscriptionMatchedStatus

DDS::DataReaderListener::on_subscription_matched