RTI Connext Modern C++ API
Version 5.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. | |
const bool & | enable_sample_replication () const |
Causes the QueueProducer to write all the samples with the dds::sub::SampleInfo::flag including the bit SampleFlagBits::REPLICATE_SAMPLE. | |
QueueProducerParams & | enable_wait_for_ack (const bool enable) |
Enables the Queuing Service's 'Acknowledgment Management' feature for the QueueProducer. | |
Public Member Functions inherited from rti::queuing::QueueEntityParams< QueueProducerParams > | |
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. | |
QueueProducerParams & | shared_subscriber_name (const std::string &name) |
Sets the SharedSubscriber name associated with the SharedReaderQueues. | |
QueueProducerParams & | entity_name (const std::string &name) |
Sets the name of the QueueEntity. | |
Public Member Functions inherited from rti::request::detail::EntityParamsWithSetters< ActualEntity > | |
ActualEntity & | service_name (const std::string &name) |
ActualEntity & | request_topic_name (const std::string &name) |
ActualEntity & | reply_topic_name (const std::string &name) |
ActualEntity & | datawriter_qos (const dds::core::optional< dds::pub::qos::DataWriterQos > &qos) |
ActualEntity & | datareader_qos (const dds::core::optional< dds::sub::qos::DataReaderQos > &qos) |
ActualEntity & | publisher (dds::pub::Publisher publisher) |
ActualEntity & | subscriber (dds::sub::Subscriber subscriber) |
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 SampleFlagBits::REPLICATE_SAMPLE.
When this value is set to true, all the samples are written with the associated metadata containing the bit SampleFlagBits::REPLICATE_SAMPLE. 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