How do I install the Smoke Zenoh Mqtt Ps Mqtt Publisher Zenoh Subscriber skill?

Run npx skillmds@latest add plevasseur/smoke-zenoh-mqtt-ps-mqtt-publisher-zenoh-subscriber in your terminal (requires Node.js), paste this page's agent-chat prompt into Claude, Cursor, or any MCP-connected agent, or download the SKILL.md file and copy it into your agent's skills directory.

Is Smoke Zenoh Mqtt Ps Mqtt Publisher Zenoh Subscriber safe to use?

This skill has not completed SkillMD's automated safety review yet. Capability flags: docs only. SkillMD never runs a skill's scripts for you; review the SKILL.md before installing.

Which AI agents work with Smoke Zenoh Mqtt Ps Mqtt Publisher Zenoh Subscriber?

This skill is tagged as working with Claude Code, Claude.ai, OpenAI Codex. SKILL.md is an open format, so most agents that read a skills directory can load it too.

Is Smoke Zenoh Mqtt Ps Mqtt Publisher Zenoh Subscriber free to use?

Yes. Installing skills from SkillMD is free. This skill is licensed under Apache-2.

Who published Smoke Zenoh Mqtt Ps Mqtt Publisher Zenoh Subscriber?

PLeVasseur (@plevasseur) published this skill. Their other Agent Skills are listed on their SkillMD profile.

Smoke Zenoh Mqtt Ps Mqtt Publisher Zenoh Subscriber by plevasseur

Name: Smoke Zenoh Mqtt Ps Mqtt Publisher Zenoh Subscriber
Rating: 4.2 (5 reviews)
Author: PLeVasseur

File contents

Scope

Run and validate this binary set:

Broker: utils/mosquitto/docker-compose.yaml
Streamer: configurable-streamer
Publisher: example-streamer-uses bin mqtt_publisher
Subscriber: example-streamer-uses bin zenoh_subscriber

Execution

Setup from repo root:
- source build/envsetup.sh highest
- export REPORT_DIR="$OPENCODE_CONFIG_DIR/reports/transport-smoke-skills/smoke-zenoh-mqtt-ps-mqtt-publisher-zenoh-subscriber"
- mkdir -p "$REPORT_DIR"
Build binaries:
- cargo build -p configurable-streamer
- cargo build -p example-streamer-uses --bin mqtt_publisher --features mqtt-transport
- cargo build -p example-streamer-uses --bin zenoh_subscriber --features zenoh-transport
Start broker:
- docker compose -f utils/mosquitto/docker-compose.yaml up -d
Start streamer from configurable-streamer:
- source ../build/envsetup.sh highest
- RUST_LOG="up_streamer=debug,up_transport_mqtt5=debug" cargo run -- --config "CONFIG.json5" > "$REPORT_DIR/streamer.log" 2>&1 & echo $! > "$REPORT_DIR/streamer.pid"
Start subscriber from repo root (aligned with static subscription sink URI):
- source build/envsetup.sh highest
- RUST_LOG=info cargo run -p example-streamer-uses --bin zenoh_subscriber --features zenoh-transport -- --uauthority authority-b --uentity 0x5678 --uversion 0x1 --resource 0x1234 --source-authority authority-a --source-uentity 0x5BA0 --source-uversion 0x1 --source-resource 0x8001 > "$REPORT_DIR/subscriber.log" 2>&1 & echo $! > "$REPORT_DIR/subscriber.pid"
Run publisher from repo root:
- source build/envsetup.sh highest
- export RUST_LOG="info,up_transport_mqtt5=debug,example_streamer_uses=debug"
- timeout 45s cargo run -p example-streamer-uses --bin mqtt_publisher --features mqtt-transport -- --broker-uri localhost:1883 > "$REPORT_DIR/publisher.log" 2>&1; printf '%s\n' "$?" > "$REPORT_DIR/publisher.exit"

Validation

Publisher emitted traffic: rg -n "Sending Publish message" "$REPORT_DIR/publisher.log"
Subscriber received traffic: rg -n "PublishReceiver: Received a message" "$REPORT_DIR/subscriber.log"
Streamer forwarded traffic: rg -n "Sending on out_transport succeeded" "$REPORT_DIR/streamer.log"

Pass only when all three checks match.

Teardown

kill -INT "$(cat "$REPORT_DIR/subscriber.pid")" "$(cat "$REPORT_DIR/streamer.pid")" || true
If still alive: kill -TERM "$(cat "$REPORT_DIR/subscriber.pid")" "$(cat "$REPORT_DIR/streamer.pid")" || true
docker compose -f utils/mosquitto/docker-compose.yaml down
Verify: pgrep -fa "configurable-streamer|mqtt_publisher|zenoh_subscriber" || true

---name: smoke-zenoh-mqtt-ps-mqtt-publisher-zenoh-subscriberdescription: Validate MQTT publisher to Zenoh subscriber pub/sub forwarding through configurable-streamer.license: Apache-2.0---## ScopeRun and validate this binary set:- Broker: `utils/mosquitto/docker-compose.yaml`- Streamer: `configurable-streamer`- Publisher: `example-streamer-uses` bin `mqtt_publisher`- Subscriber: `example-streamer-uses` bin `zenoh_subscriber`## Execution1. Setup from repo root: - `source build/envsetup.sh highest` - `export REPORT_DIR="$OPENCODE_CONFIG_DIR/reports/transport-smoke-skills/smoke-zenoh-mqtt-ps-mqtt-publisher-zenoh-subscriber"` - `mkdir -p "$REPORT_DIR"`2. Build binaries: - `cargo build -p configurable-streamer` - `cargo build -p example-streamer-uses --bin mqtt_publisher --features mqtt-transport` - `cargo build -p example-streamer-uses --bin zenoh_subscriber --features zenoh-transport`3. Start broker: - `docker compose -f utils/mosquitto/docker-compose.yaml up -d`4. Start streamer from `configurable-streamer`: - `source ../build/envsetup.sh highest` - `RUST_LOG="up_streamer=debug,up_transport_mqtt5=debug" cargo run -- --config "CONFIG.json5" > "$REPORT_DIR/streamer.log" 2>&1 & echo $! > "$REPORT_DIR/streamer.pid"`5. Start subscriber from repo root (aligned with static subscription sink URI): - `source build/envsetup.sh highest` - `RUST_LOG=info cargo run -p example-streamer-uses --bin zenoh_subscriber --features zenoh-transport -- --uauthority authority-b --uentity 0x5678 --uversion 0x1 --resource 0x1234 --source-authority authority-a --source-uentity 0x5BA0 --source-uversion 0x1 --source-resource 0x8001 > "$REPORT_DIR/subscriber.log" 2>&1 & echo $! > "$REPORT_DIR/subscriber.pid"`6. Run publisher from repo root: - `source build/envsetup.sh highest` - `export RUST_LOG="info,up_transport_mqtt5=debug,example_streamer_uses=debug"` - `timeout 45s cargo run -p example-streamer-uses --bin mqtt_publisher --features mqtt-transport -- --broker-uri localhost:1883 > "$REPORT_DIR/publisher.log" 2>&1; printf '%s\n' "$?" > "$REPORT_DIR/publisher.exit"`## Validation- Publisher emitted traffic: `rg -n "Sending Publish message" "$REPORT_DIR/publisher.log"`- Subscriber received traffic: `rg -n "PublishReceiver: Received a message" "$REPORT_DIR/subscriber.log"`- Streamer forwarded traffic: `rg -n "Sending on out_transport succeeded" "$REPORT_DIR/streamer.log"`Pass only when all three checks match.## Teardown- `kill -INT "$(cat "$REPORT_DIR/subscriber.pid")" "$(cat "$REPORT_DIR/streamer.pid")" || true`- If still alive: `kill -TERM "$(cat "$REPORT_DIR/subscriber.pid")" "$(cat "$REPORT_DIR/streamer.pid")" || true`- `docker compose -f utils/mosquitto/docker-compose.yaml down`- Verify: `pgrep -fa "configurable-streamer|mqtt_publisher|zenoh_subscriber" || true`

Frequently asked questions

Smoke Zenoh Mqtt Ps Mqtt Publisher Zenoh Subscriber