Rust

[dependencies]
paho-mqtt = {git = "https://github.com/eclipse/paho.mqtt.rust", branch = "master"}
futures = { version = "0.3", features = ["compat"] } 

use std::{
    env,
    process,
    time::Duration,
    thread
};
use futures::{
    executor::block_on,
    stream::StreamExt,
};
use paho_mqtt as mqtt;

let host = "ssl://broker.qubitro.com:8883";
let dev_id = "PASTE_DEVICE_ID_HERE";
let dev_token = "PASTE_DEVICE_TOKEN_HERE";

let create_opts = mqtt::CreateOptionsBuilder::new()
    .server_uri(host)
    .persistence(mqtt::PersistenceType::None)
    .client_id(dev_id)
    .finalize();

let cli = mqtt::AsyncClient::new(create_opts).unwrap_or_else(|err| {
         println!("Error creating the client: {}", err);
         process::exit(1);
 });