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

Moved all stuff into thread

Browse Source
This commit is contained in:
Ollo
2025-11-14 22:29:52 +01:00
parent 7180acd809
commit 349f69b8ca
1 changed files with 56 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -516,6 +516,9 @@ fn main_function(parameter1: String, parameter2: Option<String>) -> ExitCode {
if GlobalConfiguration.lock().is_ok() && (GlobalConfiguration.lock().unwrap().mqttIPAddress.len() > 0)
{
// Create a thread that stays pending over incoming messages.
let handle = thread::spawn(move || {
// Define the set of options for the create.
// Use an ID for a persistent session.
let create_opts = paho_mqtt::CreateOptionsBuilder::new()
@@ -548,18 +551,27 @@ fn main_function(parameter1: String, parameter2: Option<String>) -> ExitCode {
},
}
// Subscribe to the desired topic(s).
local_mqtt.subscribe("room/ledboard", paho_mqtt::QOS_0);
// Starts the client receiving messages
let rx_queue = local_mqtt.start_consuming();
let thread_mqtt = local_mqtt.clone();
// move local instance to global scope
gmc.set_mqtt_client(Some(local_mqtt));
// Attach a closure to the client to receive callback
// on incoming messages.
let mqtt_message_for_callback = mqtt_message.clone();
// Create a thread that stays pending over incoming messages.
let handle = thread::spawn(move || {
// Subscribe to the desired topic(s).
let resultSubscribe = thread_mqtt.subscribe("room/ledboard", paho_mqtt::QOS_0);
match resultSubscribe {
Ok(_) => {
println!("MQTT | Subscribe ");
},
Err(error) => {
println!("MQTT | Subscribe failed {error:?}");
},
}
// Starts the client receiving messages
let rx_queue = thread_mqtt.start_consuming();
for mqttmsg in rx_queue.iter() {
if let Some(mqttmsg) = mqttmsg {
let topic = mqttmsg.topic();
@@ -568,17 +580,13 @@ fn main_function(parameter1: String, parameter2: Option<String>) -> ExitCode {
//println!("MQTT | {} - {}", topic, payload_str);
let mut lock = mqtt_message_for_callback.lock().unwrap();
lock.string = Some(payload_str.to_string());
println!("Received: -> {}", mqttmsg.payload_str());
println!("MQTT | Received: -> {}", mqttmsg.payload_str());
} else {
println!("Unsubscribe: connection closed");
break;
println!("MQTT | Unsubscribe: connection closed");
}
}
});
// Define the set of options for the connection
// move local instance to global scope
gmc.set_mqtt_client(Some(local_mqtt));
}
let receiver = openweathermap::init_forecast("Mannheim",