From 7f76ecc2924b82edeffd0cc1f388213bd2583d58 Mon Sep 17 00:00:00 2001
From: Dimitrios Kouros <dimitris@kouros-online.de>
Date: Sat, 15 Aug 2026 17:37:54 +0300
Subject: [PATCH] connection error

---
 src/main.rs | 10 +---------
 1 file changed, 1 insertion(+), 9 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index 3aa2f40..e82cf9b 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -27,11 +27,9 @@ async fn main() {
             task::spawn(async move {
                 publish(client.clone(), &weather).await;
             });
-            println!("{}", 100);
 
             let poll_result = time::timeout(MQTT_TIMEOUT, async {
                 let mut count = 0;
-                let mut err_count = 0;
                 loop {
                     let event = eventloop.poll().await;
                     match &event {
@@ -43,12 +41,7 @@ async fn main() {
                         }
                         Err(e) => {
                             println!("MQTT Error = {e:?}");
-                            err_count += 1;
-                            if err_count >= 5 {
-                                eprintln!("Exiting MQTT loop after 5 consecutive errors.");
-                                break;
-                            }
-                            time::sleep(Duration::from_millis(200)).await;
+                            break;
                         }
                     }
                 }
@@ -222,7 +215,6 @@ fn create_conn() -> (AsyncClient, EventLoop) {
     let mqtt_user = env::var("MQTT_USER").unwrap_or_default();
     let mqtt_password = env::var("MQTT_PASSWORD").unwrap_or_default();
 
-    println!("MQTT Broker: {}", mqtt_broker);
     let mut mqttoptions = MqttOptions::new(mqtt_client, mqtt_broker, 1883);
     mqttoptions
         .set_keep_alive(Duration::from_secs(5))