mathieu/Adafruit_MQTT_Library
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

remove unnecessary ping(), delay() & added WDT reset for connection failures

Browse Source
This commit is contained in:
ladyada 2016-01-10 01:03:59 -05:00
parent 9fb6fbf1e8
commit db47f8f3b3
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
examples/mqtt_esp8266/mqtt_esp8266.ino
View File

@ -95,8 +95,10 @@ void loop() {
MQTT_connect(); MQTT_connect();
// this is our 'wait for incoming subscription packets' busy subloop // this is our 'wait for incoming subscription packets' busy subloop
// try to spend your time here
Adafruit_MQTT_Subscribe *subscription; Adafruit_MQTT_Subscribe *subscription;
while ((subscription = mqtt.readSubscription(1000))) { while ((subscription = mqtt.readSubscription(5000))) {
if (subscription == &onoffbutton) { if (subscription == &onoffbutton) {
Serial.print(F("Got: ")); Serial.print(F("Got: "));
Serial.println((char *)onoffbutton.lastread); Serial.println((char *)onoffbutton.lastread);
@ -114,12 +116,12 @@ void loop() {
} }
// ping the server to keep the mqtt connection alive // ping the server to keep the mqtt connection alive
// NOT required if you are publishing once every KEEPALIVE seconds
/*
if(! mqtt.ping()) { if(! mqtt.ping()) {
mqtt.disconnect(); mqtt.disconnect();
} }
*/
delay(1000);
} }
// Function to connect and reconnect as necessary to the MQTT server. // Function to connect and reconnect as necessary to the MQTT server.
@ -134,11 +136,17 @@ void MQTT_connect() {
Serial.print("Connecting to MQTT... "); Serial.print("Connecting to MQTT... ");
uint8_t retries = 3;
while ((ret = mqtt.connect()) != 0) { // connect will return 0 for connected while ((ret = mqtt.connect()) != 0) { // connect will return 0 for connected
Serial.println(mqtt.connectErrorString(ret)); Serial.println(mqtt.connectErrorString(ret));
Serial.println("Retrying MQTT connection in 5 seconds..."); Serial.println("Retrying MQTT connection in 5 seconds...");
mqtt.disconnect(); mqtt.disconnect();
delay(5000); // wait 5 seconds delay(5000); // wait 5 seconds
retries--;
if (retries == 0) {
// basically die and wait for WDT to reset me
while (1);
}
} }
Serial.println("MQTT Connected!"); Serial.println("MQTT Connected!");
} }