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") {