diff --git a/Cargo.lock b/Cargo.lock index b795d306..34a21033 100644 --- a/Cargo.lock +++ b/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" diff --git a/Cargo.toml b/Cargo.toml index f0a2efa1..bd552f8e 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -14,6 +14,7 @@ members = [ "common", "runtime", "runtime/examples/example-operator", + "zenoh-logger", ] [dependencies] diff --git a/zenoh-logger/Cargo.toml b/zenoh-logger/Cargo.toml new file mode 100644 index 00000000..3b92e55b --- /dev/null +++ b/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" } diff --git a/zenoh-logger/src/main.rs b/zenoh-logger/src/main.rs new file mode 100644 index 00000000..f1c322c3 --- /dev/null +++ b/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); + } +}