LailaTheElf/mqttAutomation
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases 11 Wiki Activity

fix error message

Browse Source
This commit is contained in:
Laila van Reenen 2025-01-31 21:54:04 +01:00
parent 6c53fab871
commit 34805734c2
Signed by: LailaTheElf
GPG Key ID: 8A3EF0226518C12D
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main.rs
View File

@ -1,4 +1,4 @@
use std::fs; use std::{fs, thread::{self, Thread}, time::Duration};
use mqtt_client::{MqttMessage, Sender, Receiver}; use mqtt_client::{MqttMessage, Sender, Receiver};
use serde::Deserialize; use serde::Deserialize;
@ -139,7 +139,10 @@ impl mqtt_client::MqttTool for Automation {
let message = rx.recv(); let message = rx.recv();
match message { match message {
Err(e) => println!("ERROR: publisher: failed to receve an message ({})", e), Err(e) => {
println!("ERROR: mqttAutomation: failed to receve an message ({})", e);
thread::sleep(Duration::from_millis(500));
},
Ok(message) => { Ok(message) => {
println!("INFO : mqtt_automation: {}: {}", message.topic, message.payload); println!("INFO : mqtt_automation: {}: {}", message.topic, message.payload);
if message.topic.eq("clock/time/hour") { if message.topic.eq("clock/time/hour") {