RTI Connext .NET API (legacy)
Version 6.1.1
|
Contains the parameters for creating a RTI::Connext::Queuing::QueueConsumer<T> More...
Inherits RTI.Connext.Queuing.Infrastructure.QueueEntityParams.
Public Member Functions | |
QueueConsumerParams< T > | SetQueueTopicName (String queueTopicName) |
Sets a specific queue topic name. More... | |
QueueConsumerParams< T > | SetSharedSubscriberName (String sharedSubscriberName) |
Sets the SharedSubscriber name associated with the SharedReaderQueue from which the QueueConsumer will receive samples. More... | |
QueueConsumerParams< T > | SetQosProfile (String qosLibraryName, String qosProfileName) |
Sets a QoS profile for the DDS entities created by a QueueConsumer. More... | |
QueueConsumerParams< T > | SetDataReaderQos (DDS.DataReaderQos dataReaderQos) |
Sets the quality of service of the QueueConsumer's DataReader. More... | |
QueueConsumerParams< T > | SetSubscriber (DDS.Subscriber subscriber) |
Sets a specific Subscriber. More... | |
QueueConsumerParams< T > | SetEntityName (String entityName) |
Sets the name of the QueueConsumer. More... | |
QueueConsumerParams< T > | SetEnableAvailability (Boolean enableAvailability) |
Indicates whether the availability channel is enabled for a QueueConsumer. More... | |
QueueConsumerParams< T > | SetListener (QueueConsumerListener< T > listener) |
Sets a listener that is called when different events affecting the QueueConsumer occur. More... | |
Contains the parameters for creating a RTI::Connext::Queuing::QueueConsumer<T>
T | : | class | |
T | : | global | |
T | : | DDS.ICopyable<T> | |
T | : | new() |
|
inline |
Sets a specific queue topic name.
The queue topic name allows you to specify with which SharedReaderQueue the QueueConsumer communicates. It is a required parameter and must match the value of the topic name within the <shared_reader_queue> tag in the Queuing Service configuration. Note that for a QueueConsumer, the queue topic name is different than the DDS topic name of the underlying QueueConsumer's DataReader.
|
inline |
Sets the SharedSubscriber name associated with the SharedReaderQueue from which the QueueConsumer will receive samples.
The SharedSubscriber name is a required parameter. It must match the name of the SharedSubscriber that contains the SharedReaderQueue from which the QueueConsumer's DataReader will receive samples.
|
inline |
Sets a QoS profile for the DDS entities created by a QueueConsumer.
Specifies an XML QoS profile that will be used to configure the quality of service of the DDS entities created by a QueueConsumer.
This includes the DataReader used to receive samples from the SharedReaderQueue and the DataWriter used to report availability to the SharedReaderQueue.
Alternatively, and only for the DataReader used to receive samples, you can set the QoS using SetDataReaderQos.
qosLibraryName | The name of the QoS library |
qosProfileName | The name of the QoS profile inside the QoS library |
|
inline |
Sets the quality of service of the QueueConsumer's DataReader.
|
inline |
Sets a specific Subscriber.
By default, a QueueConsumer uses the DomainParticipant's implicit Subscriber. Sometimes a different Subscriber may be needed, for example, to use non-default SubscriberQos.
|
inline |
Sets the name of the QueueConsumer.
The name of the QueueConsumer is used along with the SetQueueTopicName to generate the QueueConsumer's GUID. By default, entity name is null, which results in the QueueConsumer's GUID being set to the underlying DataReader's virtual GUID.
|
inline |
Indicates whether the availability channel is enabled for a QueueConsumer.
When this parameter is set to true, the QueueConsumer creates a DataWriter to report its availability to the SharedReaderQueue from which the QueueConsumer receives samples.
The QueueConsumer can send availability samples to the SharedReaderQueue using the method RTI::Connext::Queuing::QueueConsumer<T>::SendAvailability(ConsumerAvailabilityParams_t)
|
inline |
Sets a listener that is called when different events affecting the QueueConsumer occur.
Referenced by RTI.Connext.Queuing.QueueReplier< TReq, TRep >.QueueReplier().