C3MA/LED-BOARD
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Mqtt subscribe works

Browse Source
This commit is contained in:
Ollo 2024-01-13 00:01:49 +01:00
parent 3ecafd4534
commit 0afbc1c508
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
client/bin/src/main.rs
View File

@ -1,5 +1,6 @@
use std::{time::Duration, fmt::format}; use std::{time::Duration, fmt::format};
use std::sync::RwLock; use std::sync::RwLock;
use openssl::string;
use paho_mqtt; use paho_mqtt;
use str; use str;
use bit::BitIndex; use bit::BitIndex;
@ -387,6 +388,7 @@ fn main_function(ipaddress: String, mqtt: Option<String>) -> ExitCode {
return ExitCode::FAILURE; return ExitCode::FAILURE;
} }
let mut mqtt_client: Option<paho_mqtt::AsyncClient> = None; let mut mqtt_client: Option<paho_mqtt::AsyncClient> = None;
let mut mqtt_message: Option<String> = None;
if mqtt.is_some() { if mqtt.is_some() {
let mqtt_ip: String = mqtt.clone().unwrap(); let mqtt_ip: String = mqtt.clone().unwrap();
// Define the set of options for the create. // Define the set of options for the create.
@ -427,7 +429,8 @@ fn main_function(ipaddress: String, mqtt: Option<String>) -> ExitCode {
let topic = msg.topic(); let topic = msg.topic();
let payload_str = msg.payload_str(); let payload_str = msg.payload_str();
println!("MQTT | {} - {}", topic, payload_str); //println!("MQTT | {} - {}", topic, payload_str);
mqtt_message = Some(payload_str.to_string());
} }
}); });