Add a zenoh logger executable to debug the missed stop messages

Cargo.lock

@@ -3044,6 +3044,14 @@ dependencies = [
  "zenoh-sync",
 ]
 
+[[package]]
+name = "zenoh-logger"
+version = "0.1.0"
+dependencies = [
+ "zenoh",
+ "zenoh-config",
+]
+
 [[package]]
 name = "zenoh-macros"
 version = "0.6.0-dev.0"

Cargo.toml

@@ -14,6 +14,7 @@ members = [
     "common",
     "runtime",
     "runtime/examples/example-operator",
+    "zenoh-logger",
 ]
 
 [dependencies]

zenoh-logger/Cargo.toml

@@ -0,0 +1,10 @@
+[package]
+name = "zenoh-logger"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+zenoh = { git = "https://github.com/eclipse-zenoh/zenoh.git" }
+zenoh-config = { git = "https://github.com/eclipse-zenoh/zenoh.git" }

zenoh-logger/src/main.rs

@@ -0,0 +1,11 @@
+use zenoh::prelude::{Receiver, ZFuture};
+
+fn main() {
+    let zenoh = zenoh::open(zenoh_config::Config::default()).wait().unwrap();
+    let mut sub = zenoh.subscribe("/**").wait().unwrap();
+
+    loop {
+        let msg = sub.receiver().recv().unwrap();
+        println!("{}", msg.key_expr);
+    }
+}