rumqtt
rumqtt copied to clipboard
AtherEnergy
Pure rust mqtt cilent
Hoo boy. There's lots of changes here. I think things should be working, and I'll be testing on the corpus of code we've built on `rumqtt` at Vivint, but I'm...
Hi, when given an invalid client key file, rumqtt panics with `'index out of bounds: the len is 0 but the index is 0'`. The stacktrace (included as an attachment)...
Hi All. I see that there are a bunch of open issues and pull requests. I'm not working at Ather anymore and it might take some time for these to...
It's certainly not perfect, but it changes a few of the panics into `Err`s. Unfortunately there's not much in the way of information that can be put into the errors...
I'm hitting `unimplemented!()` in this function, in `src/client/mqttstate.rs` (line 71): ```rust pub fn handle_outgoing_mqtt_packet(&mut self, packet: Packet) -> Result { let out = match packet { Packet::Publish(publish) => { let...
Hello, The tls example doesn't work for me, I tried the following code: ```rust use rumqtt::{MqttClient, MqttOptions, QoS}; use std::{thread, time::Duration}; fn main() { pretty_env_logger::init(); let client_id = "tls-test".to_owned(); let...
Created a patch that allows compiling without default features. I am unsure if it would break anything else except JWT stuff. So please check
Create an unbounded crossbeam_channel by default. For bounded crossbeam_channel use the 'set_notification_channel_capacity' to a value of choice. This should fix the issue #166
Hello, I would like to have dynamic subscriptions. On certain action subscription should be created, it is done by `MqttClient::subscribe`. And on another action this subscription should be deleted (as...
