From 34805734c2dbe4a6f0e769f89bbedf1a35b2a66c Mon Sep 17 00:00:00 2001 From: LailaTheElf Date: Fri, 31 Jan 2025 21:54:04 +0100 Subject: [PATCH] fix error message --- src/main.rs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/main.rs b/src/main.rs index c71e701..ca7c43b 100644 --- a/src/main.rs +++ b/src/main.rs @@ -1,4 +1,4 @@ -use std::fs; +use std::{fs, thread::{self, Thread}, time::Duration}; use mqtt_client::{MqttMessage, Sender, Receiver}; use serde::Deserialize; @@ -139,7 +139,10 @@ impl mqtt_client::MqttTool for Automation { let message = rx.recv(); 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) => { println!("INFO : mqtt_automation: {}: {}", message.topic, message.payload); if message.topic.eq("clock/time/hour") {