iot/sprocket-plugin-mqtt
1
0
Fork 0
mirror of https://gitlab.com/wirelos/sprocket-plugin-mqtt.git synced 2025-12-14 05:46:49 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix connect

Browse Source
This commit is contained in:
Partick Balsiger
2019-04-27 18:18:34 +02:00
parent 038e030069
commit 3249c1d495
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/MqttPlugin.cpp
View File

@@ -29,8 +29,7 @@ void MqttPlugin::activate(Scheduler *scheduler)
{ {
applyConfigFromFile("/mqttConfig.json"); applyConfigFromFile("/mqttConfig.json");
client = new PubSubClient(brokerHost.c_str(), brokerPort, bind(&MqttPlugin::downstreamHandler, this, _1, _2, _3), wifiClient); client = new PubSubClient(brokerHost.c_str(), brokerPort, bind(&MqttPlugin::downstreamHandler, this, _1, _2, _3), wifiClient);
enableConnectTask(scheduler);
scheduler = scheduler;
enableProcessTask(scheduler); enableProcessTask(scheduler);
PRINT_MSG(Serial, "MQTT", "plugin activated"); PRINT_MSG(Serial, "MQTT", "plugin activated");
} }
@@ -44,7 +43,7 @@ void MqttPlugin::enableConnectTask(Scheduler *scheduler)
void MqttPlugin::enableProcessTask(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); scheduler->addTask(processTask);
processTask.enable(); processTask.enable();
} }
@@ -91,10 +90,10 @@ void MqttPlugin::connect()
PRINT_MSG(Serial, "MQTT", "connected"); PRINT_MSG(Serial, "MQTT", "connected");
} else { } else {
PRINT_MSG(Serial, "MQTT", "connect failed"); PRINT_MSG(Serial, "MQTT", "connect failed");
connectTries++; //connectTries++;
if(connectTries == maxConnectTries){ //if(connectTries == maxConnectTries){
} //}
connectTask.disable(); //connectTask.disable();
} }
} }
} }