RTI Connext Modern C++ API Version 7.3.0
|
Contains the parameters for creating a QueueProducer. More...
#include <rti/queuing/QueueParams.hpp>
Public Member Functions | |
QueueProducerParams (dds::domain::DomainParticipant participant) | |
Creates a QueueProducerParams object with the participant set. More... | |
bool | enable_sample_replication () const |
Causes the QueueProducer to write all the samples with the dds::sub::SampleInfo::flag including the bit rti::core::SampleFlag::replicate. More... | |
QueueProducerParams & | enable_wait_for_ack (bool enable) |
Enables the Queuing Service's 'Acknowledgment Management' feature for the QueueProducer. More... | |
![]() | |
QueueProducerParams & | qos_profile (const std::string &qos_library_name, const std::string &qos_profile_name) |
Specifies an XML QoS profile that will be used to configure the quality of service of the DDS entities created. This includes the DataReader and DataWriter used to send and receive samples from a SharedReaderQueue. Alternatively, you can set the DataReader and DataWriter QoS using datareader_qos() and datawriter_qos() methods. If you set the DataReader QoS or the DataWriter QoS the provided values will be used instead of the QoS specified in the XML qos profile. . More... | |
QueueProducerParams & | shared_subscriber_name (const std::string &name) |
Sets the SharedSubscriber name associated with the SharedReaderQueues. More... | |
QueueProducerParams & | entity_name (const std::string &name) |
Sets the name of the QueueEntity. More... | |
Contains the parameters for creating a QueueProducer.
|
inlineexplicit |
Creates a QueueProducerParams object with the participant set.
The rest of the parameters that can be set in a QueueProducerParams object are optional.
participant | The dds::domain::DomainParticipant a QueueProducer uses to join a domain. |
|
inline |
Causes the QueueProducer to write all the samples with the dds::sub::SampleInfo::flag including the bit rti::core::SampleFlag::replicate.
When this value is set to true, all the samples are written with the associated metadata containing the bit rti::core::SampleFlag::replicate. This behavior cannot be changed once this option is enabled (no matter which operation is used to send samples).
|
inline |
Enables the Queuing Service's 'Acknowledgment Management' feature for the QueueProducer.
When this value is set to true, you can call the APIs QueueProducer::wait_for_acknowledgments(const dds::core::Duration&) and QueueProducer::wait_for_acknowledgments(const rti::core::SampleIdentity&, const dds::core::Duration&) to wait for acknowledgments from Queuing Service. These acknowledgments indicate whether or not samples have been successfully enqueued.
Notice that if you enable this feature, at some point you must call QueueProducer::wait_for_acknowledgments(const dds::core::Duration&) or QueueProducer::wait_for_acknowledgments(const rti::core::SampleIdentity&, const dds::core::Duration&). Otherwise, the QueueProducer's memory will grow unbounded, since it will keep some state per sample.
You must also set the XML tag <app_ack_sample_to_producer> under <queue_qos>/<reliability> to true.
[default] true
References rti::util::network_capture::enable().