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

default to MQTT_PROTOCOL_LEVEL 4

Browse Source
This commit is contained in:
Todd Treece 2015-10-01 12:00:56 -04:00
parent 798e37b4de
commit a0520d3265
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
Adafruit_MQTT.cpp
View File

@ -119,13 +119,13 @@ int8_t Adafruit_MQTT::connect() {
// Connect to the server. // Connect to the server.
if (!connectServer()) if (!connectServer())
return -1; return -1;
// Construct and send connect packet. // Construct and send connect packet.
uint8_t len = connectPacket(buffer); uint8_t len = connectPacket(buffer);
if (!sendPacket(buffer, len)) if (!sendPacket(buffer, len))
return -1; return -1;
// Read connect response packet and verify it // Read connect response packet and verify it
len = readPacket(buffer, 4, CONNECT_TIMEOUT_MS); len = readPacket(buffer, 4, CONNECT_TIMEOUT_MS);
if (len != 4) if (len != 4)
return -1; return -1;
@ -143,7 +143,7 @@ int8_t Adafruit_MQTT::connect() {
uint8_t len = subscribePacket(buffer, subscriptions[i]->topic, subscriptions[i]->qos); uint8_t len = subscribePacket(buffer, subscriptions[i]->topic, subscriptions[i]->qos);
if (!sendPacket(buffer, len)) if (!sendPacket(buffer, len))
return -1; return -1;
// Get SUBACK // Get SUBACK
len = readPacket(buffer, 5, CONNECT_TIMEOUT_MS); len = readPacket(buffer, 5, CONNECT_TIMEOUT_MS);
DEBUG_PRINT(F("SUBACK:\t")); DEBUG_PRINT(F("SUBACK:\t"));

6
Adafruit_MQTT.h
View File

@ -29,7 +29,7 @@
#endif #endif
// Uncomment/comment to turn on/off debug output messages. // Uncomment/comment to turn on/off debug output messages.
//#define MQTT_DEBUG #define MQTT_DEBUG
// Set where debug messages will be printed. // Set where debug messages will be printed.
#define DEBUG_PRINTER Serial #define DEBUG_PRINTER Serial
@ -45,7 +45,9 @@
#define DEBUG_PRINTBUFFER(buffer, len) {} #define DEBUG_PRINTBUFFER(buffer, len) {}
#endif #endif
#define MQTT_PROTOCOL_LEVEL 3 #ifndef MQTT_PROTOCOL_LEVEL
#define MQTT_PROTOCOL_LEVEL 4
#endif
#define MQTT_CTRL_CONNECT 0x01 #define MQTT_CTRL_CONNECT 0x01
#define MQTT_CTRL_CONNECTACK 0x02 #define MQTT_CTRL_CONNECTACK 0x02