diff --git a/core/Publisher.cxx b/core/Publisher.cxx index d2c2900..015eef3 100644 --- a/core/Publisher.cxx +++ b/core/Publisher.cxx @@ -157,7 +157,7 @@ PublisherApp::PublisherApp( publisher_->get_default_datawriter_qos(writer_qos); writer_qos.reliability().kind = ReliabilityQosPolicyKind::RELIABLE_RELIABILITY_QOS; writer_qos.reliability().max_blocking_time = Duration_t(1, 0); - writer_qos.durability().kind = DurabilityQosPolicyKind::TRANSIENT_LOCAL_DURABILITY_QOS; + writer_qos.durability().kind = DurabilityQosPolicyKind::VOLATILE_DURABILITY_QOS; writer_qos.history().kind = HistoryQosPolicyKind::KEEP_LAST_HISTORY_QOS; writer_qos.history().depth = 1; writer_qos.resource_limits().max_samples = 200; diff --git a/core/Subscriber.cxx b/core/Subscriber.cxx index 0c222f1..9cf04eb 100644 --- a/core/Subscriber.cxx +++ b/core/Subscriber.cxx @@ -197,7 +197,7 @@ SubscriberApp::SubscriberApp( subscriber_->get_default_datareader_qos(reader_qos); reader_qos.reliability().kind = ReliabilityQosPolicyKind::RELIABLE_RELIABILITY_QOS; reader_qos.reliability().max_blocking_time = Duration_t(1, 0); - reader_qos.durability().kind = DurabilityQosPolicyKind::TRANSIENT_LOCAL_DURABILITY_QOS; + reader_qos.durability().kind = DurabilityQosPolicyKind::VOLATILE_DURABILITY_QOS; reader_qos.history().kind = HistoryQosPolicyKind::KEEP_LAST_HISTORY_QOS; reader_qos.history().depth = 1; reader_qos.resource_limits().max_samples = 200; @@ -278,7 +278,7 @@ SubscriberApp::SubscriberApp( subscriber_->get_default_datareader_qos(reader_qos); reader_qos.reliability().kind = ReliabilityQosPolicyKind::RELIABLE_RELIABILITY_QOS; reader_qos.reliability().max_blocking_time = Duration_t(1, 0); - reader_qos.durability().kind = DurabilityQosPolicyKind::TRANSIENT_LOCAL_DURABILITY_QOS; + reader_qos.durability().kind = DurabilityQosPolicyKind::VOLATILE_DURABILITY_QOS; reader_qos.history().kind = HistoryQosPolicyKind::KEEP_LAST_HISTORY_QOS; reader_qos.history().depth = 1; reader_qos.resource_limits().max_samples = 200; @@ -305,7 +305,7 @@ SubscriberApp::SubscriberApp( subscriber_->get_default_datareader_qos(reader_qos); reader_qos.reliability().kind = ReliabilityQosPolicyKind::RELIABLE_RELIABILITY_QOS; reader_qos.reliability().max_blocking_time = Duration_t(1, 0); - reader_qos.durability().kind = DurabilityQosPolicyKind::TRANSIENT_LOCAL_DURABILITY_QOS; + reader_qos.durability().kind = DurabilityQosPolicyKind::VOLATILE_DURABILITY_QOS; reader_qos.history().kind = HistoryQosPolicyKind::KEEP_LAST_HISTORY_QOS; reader_qos.history().depth = 1; reader_qos.resource_limits().max_samples = 200; diff --git a/httpserver/Subscriber.cxx b/httpserver/Subscriber.cxx index a60c03b..93b9644 100644 --- a/httpserver/Subscriber.cxx +++ b/httpserver/Subscriber.cxx @@ -85,7 +85,7 @@ SubscriberApp::SubscriberApp( DataReaderQos reader_qos = DATAREADER_QOS_DEFAULT; subscriber_->get_default_datareader_qos(reader_qos); reader_qos.reliability().kind = ReliabilityQosPolicyKind::RELIABLE_RELIABILITY_QOS; - reader_qos.durability().kind = DurabilityQosPolicyKind::TRANSIENT_LOCAL_DURABILITY_QOS; + reader_qos.durability().kind = DurabilityQosPolicyKind::VOLATILE_DURABILITY_QOS; reader_qos.history().kind = HistoryQosPolicyKind::KEEP_LAST_HISTORY_QOS; reader_ = subscriber_->create_datareader(topic_, reader_qos, this, StatusMask::all()); if (reader_ == nullptr) diff --git a/mqttdds/Publisher.cxx b/mqttdds/Publisher.cxx index 5b41e29..686e9be 100644 --- a/mqttdds/Publisher.cxx +++ b/mqttdds/Publisher.cxx @@ -159,7 +159,7 @@ PublisherApp::PublisherApp( publisher_->get_default_datawriter_qos(writer_qos); writer_qos.reliability().kind = ReliabilityQosPolicyKind::RELIABLE_RELIABILITY_QOS; writer_qos.reliability().max_blocking_time = Duration_t(1, 0); - writer_qos.durability().kind = DurabilityQosPolicyKind::TRANSIENT_LOCAL_DURABILITY_QOS; + writer_qos.durability().kind = DurabilityQosPolicyKind::VOLATILE_DURABILITY_QOS; writer_qos.history().kind = HistoryQosPolicyKind::KEEP_LAST_HISTORY_QOS; writer_qos.history().depth = 1; writer_qos.resource_limits().max_samples = 200; diff --git a/mqttdds/Subscriber.cxx b/mqttdds/Subscriber.cxx index 48cd7e3..1afabe2 100644 --- a/mqttdds/Subscriber.cxx +++ b/mqttdds/Subscriber.cxx @@ -189,7 +189,7 @@ SubscriberApp::SubscriberApp( subscriber_->get_default_datareader_qos(reader_qos); reader_qos.reliability().kind = ReliabilityQosPolicyKind::RELIABLE_RELIABILITY_QOS; reader_qos.reliability().max_blocking_time = Duration_t(1, 0); - reader_qos.durability().kind = DurabilityQosPolicyKind::TRANSIENT_LOCAL_DURABILITY_QOS; + reader_qos.durability().kind = DurabilityQosPolicyKind::VOLATILE_DURABILITY_QOS; reader_qos.history().kind = HistoryQosPolicyKind::KEEP_LAST_HISTORY_QOS; reader_qos.history().depth = 1; reader_qos.resource_limits().max_samples = 200; diff --git a/print/Publisher.cxx b/print/Publisher.cxx index 0b1dced..d060459 100644 --- a/print/Publisher.cxx +++ b/print/Publisher.cxx @@ -92,7 +92,7 @@ PublisherApp::PublisherApp( DataWriterQos writer_qos = DATAWRITER_QOS_DEFAULT; publisher_->get_default_datawriter_qos(writer_qos); writer_qos.reliability().kind = ReliabilityQosPolicyKind::RELIABLE_RELIABILITY_QOS; - writer_qos.durability().kind = DurabilityQosPolicyKind::TRANSIENT_LOCAL_DURABILITY_QOS; + writer_qos.durability().kind = DurabilityQosPolicyKind::VOLATILE_DURABILITY_QOS; writer_qos.history().kind = HistoryQosPolicyKind::KEEP_LAST_HISTORY_QOS; writer_ = publisher_->create_datawriter(topic_, writer_qos, this, StatusMask::all()); if (writer_ == nullptr)