jeans/openHASP
jeans/openHASP
1
0
Fork 0
mirror of https://github.com/HASwitchPlate/openHASP.git synced 2025-07-25 20:26:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Handle mqtt not connected

Browse Source
This commit is contained in:
fvanroie 2020-03-10 21:58:49 +01:00
parent 3f228e3f47
commit d07a8e94c9
1 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/hasp_mqtt.cpp
View File

@ -99,19 +99,23 @@ void IRAM_ATTR mqttSendState(const char * subtopic, const char * payload)
// light = 0/1 // light = 0/1
// brightness = 100 // brightness = 100
char mqttTopic[128];
// char mqttPayload[128 * 5]; // char mqttPayload[128 * 5];
snprintf_P(mqttTopic, sizeof(mqttTopic), PSTR("%sstate/%s"), mqttNodeTopic.c_str(), subtopic); if(mqttClient.connected()) {
mqttClient.publish(mqttTopic, payload); char mqttTopic[128];
snprintf_P(mqttTopic, sizeof(mqttTopic), PSTR("%sstate/%s"), mqttNodeTopic.c_str(), subtopic);
mqttClient.publish(mqttTopic, payload);
String msg((char *)0); String msg((char *)0);
msg.reserve(512); msg.reserve(512);
msg = F("MQTT OUT: "); msg = F("MQTT OUT: ");
msg += mqttTopic; msg += mqttTopic;
msg += " = "; msg += " = ";
msg += payload; msg += payload;
debugPrintln(msg); debugPrintln(msg);
} else {
errorPrintln(F("MQTT: %sNot connected"));
}
// as json // as json
// snprintf_P(mqttTopic, sizeof(mqttTopic), PSTR("%sstate/json"), mqttNodeTopic.c_str()); // snprintf_P(mqttTopic, sizeof(mqttTopic), PSTR("%sstate/json"), mqttNodeTopic.c_str());