extern crate pretty_env_logger; extern crate rumqtt; //use rumqtt::{MqttClient, MqttOptions}; //use std::thread; fn main() { // pretty_env_logger::init(); // let mqtt_options = MqttOptions::new("test-id-1", "localhost", 1883); // let (mut mqtt_client, notifications) = MqttClient::start(mqtt_options); // thread::spawn(move || { // // let mqtt_options = MqttOptions::new("test-id-2", "localhost", 1883).set_keep_alive(120); // // mqtt_client.reconnect(mqtt_options).unwrap(); // }); // for notification in notifications { // println!("{:?}", notification) // } }