rumqtt
rumqtt copied to clipboard
Pure rust mqtt cilent
Upon higher load conditions incoming notifications are silently dropped (unless logging is configured). The `try_send` in `handle_notification` will return a `full`. https://github.com/AtherEnergy/rumqtt/blob/7a07a00b779d172b14639161b0d99df7b284335f/src/client/connection.rs#L491-L499 The consumer has no possibility to detect or...
Hey there! I'm using v0.30.1 of rumqtt. After some testing, I found that calling `resume` actually does no behave as expected. When I call `pause` on the client, it automatically...
When the connection to the broker fails, rumqtt logs: ```log ERROR 2019-04-29T13:16:50Z: rumqtt::client::connection: Connection error = Error(Inner(MqttConnectionRefused(5))) ``` In this case, I would have liked to see "not authorised" or...
There used to be set_should_verify_ca method on MqttOptions type, along with other methods that are all gone, which is fine but I'm not sure what is the equivalent of set_should_verify_ca...
does anyone have an example of running both actix and rumqtt?
#94 Sometimes users might want to send acks **after** handling incoming publishes. Add compile time feature to disable auto acks and provide method to send ack
In our case we don't need any http-related features rumqtt, but they can't be disabled at the moment. ```toml rumqtt = { version = "0.30", default-features = false } ```...
for AWS IoT - https://aws.amazon.com/jp/blogs/iot/mqtt-with-tls-client-authentication-on-port-443-why-it-is-useful-and-how-it-works/ with rustls - https://github.com/ctz/rustls (but native-tls not yet https://github.com/sfackler/rust-native-tls/issues/49)