mqtt5 0.31.2

Complete MQTT v5.0 platform with high-performance async client and full-featured broker supporting TCP, TLS, WebSocket, authentication, bridging, and resource monitoring
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

#![allow(clippy::large_futures)]

mod common;
use common::TestBroker;
use mqtt5::time::Duration;
use mqtt5::MqttClient;

#[tokio::test]
async fn test_simple_connection_and_subscribe() {
    // Start test broker
    let broker = TestBroker::start().await;

    println!("Creating client...");
    let client = MqttClient::new("debug-client");

    println!("Connecting to {}...", broker.address());
    match client.connect(broker.address()).await {
        Ok(()) => println!("Connected successfully"),
        Err(e) => {
            eprintln!("Failed to connect: {e:?}");
            return;
        }
    }

    println!("Setting up subscription...");
    let result = client
        .subscribe("test/topic", |msg| {
            println!("Received message on {}: {:?}", msg.topic, msg.payload);
        })
        .await;

    match result {
        Ok(qos) => println!("Subscribed with QoS: {qos:?}"),
        Err(e) => {
            eprintln!("Failed to subscribe: {e:?}");
            return;
        }
    }

    println!("Publishing message...");
    match client.publish("test/topic", b"Hello MQTT").await {
        Ok(packet_id) => println!("Published with packet_id: {packet_id:?}"),
        Err(e) => {
            eprintln!("Failed to publish: {e:?}");
            return;
        }
    }

    println!("Waiting for message...");
    tokio::time::sleep(Duration::from_secs(2)).await;

    println!("Disconnecting...");
    match client.disconnect().await {
        Ok(()) => println!("Disconnected successfully"),
        Err(e) => eprintln!("Failed to disconnect: {e:?}"),
    }
}