|
@ -235,7 +235,7 @@ class PubMqtt { |
|
|
else |
|
|
else |
|
|
snprintf(mTopic.data(), mTopic.size(), "%s", subTopic); |
|
|
snprintf(mTopic.data(), mTopic.size(), "%s", subTopic); |
|
|
|
|
|
|
|
|
if(!mCfgMqtt->enableRetain) |
|
|
if(!mCfgMqtt->enableRetain && String(mTopic.data()) != String(mLwtTopic.data())) |
|
|
retained = false; |
|
|
retained = false; |
|
|
|
|
|
|
|
|
mClient.publish(mTopic.data(), qos, retained, payload); |
|
|
mClient.publish(mTopic.data(), qos, retained, payload); |
|
|