From 3249c1d495128eb4343f6c5a5952b3b3fa534805 Mon Sep 17 00:00:00 2001
From: Partick Balsiger <patrick@brudi.com>
Date: Sat, 27 Apr 2019 18:18:34 +0200
Subject: [PATCH] fix connect

---
 src/MqttPlugin.cpp | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

diff --git a/src/MqttPlugin.cpp b/src/MqttPlugin.cpp
index 57452a6..7753773 100755
--- a/src/MqttPlugin.cpp
+++ b/src/MqttPlugin.cpp
@@ -29,8 +29,7 @@ void MqttPlugin::activate(Scheduler *scheduler)
 {
     applyConfigFromFile("/mqttConfig.json");
     client = new PubSubClient(brokerHost.c_str(), brokerPort, bind(&MqttPlugin::downstreamHandler, this, _1, _2, _3), wifiClient);
-    
-    scheduler = scheduler;
+    enableConnectTask(scheduler);
     enableProcessTask(scheduler);
     PRINT_MSG(Serial, "MQTT", "plugin activated");
 }
@@ -44,7 +43,7 @@ void MqttPlugin::enableConnectTask(Scheduler *scheduler)
 
 void MqttPlugin::enableProcessTask(Scheduler *scheduler)
 {
-    processTask.set(TASK_MILLISECOND * 5, TASK_FOREVER, bind(&MqttPlugin::loop, this));
+    processTask.set(TASK_MILLISECOND * 5, TASK_FOREVER, bind(&PubSubClient::loop, client));
     scheduler->addTask(processTask);
     processTask.enable();
 }
@@ -91,10 +90,10 @@ void MqttPlugin::connect()
             PRINT_MSG(Serial, "MQTT", "connected");
         } else {
             PRINT_MSG(Serial, "MQTT", "connect failed");
-            connectTries++;
-            if(connectTries == maxConnectTries){
-            }
-                connectTask.disable();
+            //connectTries++;
+            //if(connectTries == maxConnectTries){
+            //}
+            //connectTask.disable();
         }
     }
 }