From fa85be2df546cb11428c81f2c663f78ccc7976b6 Mon Sep 17 00:00:00 2001 From: "ishak jmilou.ishak" Date: Wed, 8 Jan 2025 14:18:46 +0100 Subject: [PATCH] removed mqtt check --- src/C++/Driver/src/main.cpp | 14 -------------- 1 file changed, 14 deletions(-) diff --git a/src/C++/Driver/src/main.cpp b/src/C++/Driver/src/main.cpp index adff2e0..22d8669 100644 --- a/src/C++/Driver/src/main.cpp +++ b/src/C++/Driver/src/main.cpp @@ -17,7 +17,6 @@ void parseMQTT(std::string message); void CapnSend(); void reconnectKobuki(); void monitorKobukiConnection(); -void monitorMQTTConnection(); // ip, clientID, username, password MqttClient client("ws://145.92.224.21/ws/", "KobukiRPI", "rpi", "rpiwachtwoordofzo"); // create a client object @@ -34,8 +33,6 @@ void setup() { client.subscribe("home/commands"); std::thread monitorThread(monitorKobukiConnection); - std::thread mqttMonitorThread(monitorMQTTConnection); - mqttMonitorThread.detach(); monitorThread.detach(); } @@ -83,17 +80,6 @@ void monitorKobukiConnection() { } } -void monitorMQTTConnection() { - while (true) { - if (!client.isConnected()) { // Controleer of de client nog verbonden is - std::cerr << "MQTT verbinding verloren. Probeer opnieuw te verbinden..." << std::endl; - client.connect(); - client.subscribe("home/commands"); - } - std::this_thread::sleep_for(std::chrono::seconds(5)); // Controleer iedere 5 seconden - } -} - std::string readMQTT() { static std::string lastMessage;