Updated Zenoh subscriber declaration to undeclare subscribers when re…

…ferences are dropped. (#356)
eclipse-zenoh · Oct 2, 2024 · 3701bf3 · 3701bf3
1 parent ada24f8
commit 3701bf3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/zenoh-plugin-dds/src/route_zenoh_dds.rs b/zenoh-plugin-dds/src/route_zenoh_dds.rs
@@ -186,6 +186,7 @@ impl RouteZenohDDS<'_> {
                 .zsession
                 .declare_subscriber(ke.clone())
                 .callback(subscriber_callback)
+                .undeclare_on_drop(true)
                 .allowed_origin(Locality::Remote) // Allow only remote publications to avoid loops
                 .querying()
                 .query_timeout(plugin.config.queries_timeout)
@@ -203,6 +204,7 @@ impl RouteZenohDDS<'_> {
                 .zsession
                 .declare_subscriber(ke.clone())
                 .callback(subscriber_callback)
+                .undeclare_on_drop(true)
                 .allowed_origin(Locality::Remote) // Allow only remote publications to avoid loops
                 .await
                 .map_err(|e| {