hihi, use the new qos and retain fields

2025-01-30 11:40:16 +01:00
parent c924081133
commit 858e6f2c63
1 changed files with 1 additions and 1 deletions
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -77,7 +77,7 @@ pub mod mqtt_client {
                Err(e) => println!("ERROR: publisher: failed to receve an message ({})", e),
                Ok(msg) => {
                    println!("INFO : publisher: topic={}; payload={}", msg.topic, msg.payload);
-                    match client.publish(msg.topic, QoS::AtMostOnce, false, msg.payload) {
+                    match client.publish(msg.topic, msg.qos, msg.retain, msg.payload) {
                        Err(_n) => println!("ERROR: publisher: failed to publish"),
                        Ok(_n) => {}
                    }