diff --git a/src/publisher/pubMqtt.h b/src/publisher/pubMqtt.h index 721cc2ff..06631bdd 100644 --- a/src/publisher/pubMqtt.h +++ b/src/publisher/pubMqtt.h @@ -238,6 +238,10 @@ class PubMqtt { if(!mCfgMqtt->enableRetain) retained = false; + // LWT messages should always be retained + if(strcmp(mTopic.data(), mLwtTopic.data()) == 0) + retained = true; + mClient.publish(mTopic.data(), qos, retained, payload); yield(); mTxCnt++;