github/esphome
2
0
Fork 0
mirror of https://github.com/esphome/esphome.git synced 2026-10-18 12:12:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Reconnect when a subscription does not fit instead of only warning

Browse Source
This commit is contained in:
J. Nick Koston
2026-10-14 10:46:59 -10:00
parent fb52e1679d
commit f6830cc719
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
esphome/components/mqtt/mqtt_client.cpp
+5 -2
View File
@@ -485,10 +485,13 @@ void MQTTClientComponent::add_subscription_(std::string &&topic, mqtt_subscripti
.resubscribe_timeout = 0,
});
#if defined(USE_ESP8266) || defined(USE_LIBRETINY)
// Too long for the current connection: reconnect so start_connect_() grows the buffer. This happens at boot
// when an IP broker connects from setup() before the entities subscribe.
if (subscription.topic.size() > this->max_topic_length_ &&
(this->state_ == MQTT_CLIENT_CONNECTING || this->state_ == MQTT_CLIENT_CONNECTED)) {
ESP_LOGW(TAG, "Topic '%s' is longer than %u characters; its messages arrive after the next reconnect",
subscription.topic.c_str(), this->max_topic_length_);
ESP_LOGD(TAG, "Reconnecting to fit a %zu character topic", subscription.topic.size());
this->mqtt_backend_.disconnect();
this->state_ = MQTT_CLIENT_DISCONNECTED;
}
#endif
this->resubscribe_subscription_(&subscription);