mqtt-async-client-rs
An MQTT 3.1.1 client written in Rust, using async functions and tokio.
- Repository: https://github.com/fluffysquirrels/mqtt-async-client-rs
- Documentation: https://docs.rs/mqtt-async-client
- Cargo crate: https://crates.io/crates/mqtt-async-client
- CI builds on Travis CI: https://travis-ci.com/fluffysquirrels/mqtt-async-client-rs
Pull requests and Github issues welcome!
To run automated tests
Simply run cargo test.
The integration tests require an MQTT broker to run against, see the
instructions in ${REPO}/tests/integration_test.rs.
Run the test command-line app
Run cargo run --bin mqttc to print usage.
The test app requires an MQTT broker to run against, see the
instructions in ${REPO}/tests/integration_test.rs.
Run cargo run --bin mqttc -- --host localhost publish topic payload
to publish payload payload to topic topic.
Run RUST_LOG="info" cargo run --bin mqttc -- --host localhost subscribe topic
to subscribe to topic topic and print any messages that are published to it.
Changelog
0.1.5
Correctly connect only once when automatic_connect is disabled.
0.1.4
Missing ping responses should cause a disconnect even when keepalive > op timeout.
Publish with retain flag.
0.1.3
Added timeouts to disconnect, and publish when QoS=0.
0.1.2
Enable automatic reconnects by default.
This tracks subscriptions and replays them after reconnecting. No publish retries yet.