jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-17 18:27:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix initial mqtt subcribe cooldown timeout (#116904)

Browse Source
This commit is contained in:
Jan Bouwhuis 2024-05-06 14:32:37 +02:00 committed by GitHub
parent 5c4afe55fd
commit 4b8b9ce92d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
homeassistant/components/mqtt/client.py
View File

@ -83,7 +83,7 @@ if TYPE_CHECKING:
_LOGGER = logging.getLogger(__name__) _LOGGER = logging.getLogger(__name__)
DISCOVERY_COOLDOWN = 5 DISCOVERY_COOLDOWN = 5
INITIAL_SUBSCRIBE_COOLDOWN = 1.0 INITIAL_SUBSCRIBE_COOLDOWN = 3.0
SUBSCRIBE_COOLDOWN = 0.1 SUBSCRIBE_COOLDOWN = 0.1
UNSUBSCRIBE_COOLDOWN = 0.1 UNSUBSCRIBE_COOLDOWN = 0.1
TIMEOUT_ACK = 10 TIMEOUT_ACK = 10
@ -885,6 +885,7 @@ class MQTT:
qos=birth_message.qos, qos=birth_message.qos,
retain=birth_message.retain, retain=birth_message.retain,
) )
_LOGGER.info("MQTT client initialized, birth message sent")
@callback @callback
def _async_mqtt_on_connect( def _async_mqtt_on_connect(
@ -944,6 +945,7 @@ class MQTT:
name="mqtt re-subscribe", name="mqtt re-subscribe",
) )
self._subscribe_debouncer.set_timeout(SUBSCRIBE_COOLDOWN) self._subscribe_debouncer.set_timeout(SUBSCRIBE_COOLDOWN)
_LOGGER.info("MQTT client initialized")
self._async_connection_result(True) self._async_connection_result(True)