diff --git a/tools/esp8266/app.cpp b/tools/esp8266/app.cpp index 38b75e6e..dbb3ee9e 100644 --- a/tools/esp8266/app.cpp +++ b/tools/esp8266/app.cpp @@ -930,7 +930,7 @@ void app::sendMqttDiscoveryConfig(void) { } serializeJson(doc, buffer); - mMqtt.sendMsg2(discoveryTopic, buffer); + mMqtt.sendMsg2(discoveryTopic, buffer, true); doc.clear(); yield(); diff --git a/tools/esp8266/mqtt.h b/tools/esp8266/mqtt.h index 853cd9ba..89570344 100644 --- a/tools/esp8266/mqtt.h +++ b/tools/esp8266/mqtt.h @@ -39,15 +39,15 @@ class mqtt { //DPRINTLN(DBG_VERBOSE, F("mqtt.h:sendMsg")); char top[64]; snprintf(top, 64, "%s/%s", mTopic, topic); - sendMsg2(top, msg); + sendMsg2(top, msg, false); } - void sendMsg2(const char *topic, const char *msg) { + void sendMsg2(const char *topic, const char *msg, boolean retained) { if(mAddressSet) { if(!mClient->connected()) reconnect(); if(mClient->connected()) - mClient->publish(topic, msg); + mClient->publish(topic, msg, retained); } }