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();
         }
     }
 }