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

Fix possibility that have multible topic subscribe mqtt (#6372)

Browse Source
This commit is contained in:
Pascal Vizeli 2017-03-03 10:05:52 +01:00 committed by GitHub
parent 3e70154695
commit 55f8ec8866
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
homeassistant/components/mqtt/__init__.py
View File

@ -482,17 +482,17 @@ class MQTT(object):
if not isinstance(topic, str):
raise HomeAssistantError("topic need to be a string!")
if topic in self.topics:
return
with (yield from self._paho_lock):
if topic in self.topics:
return
result, mid = yield from self.hass.loop.run_in_executor(
None, self._mqttc.subscribe, topic, qos)
yield from asyncio.sleep(0, loop=self.hass.loop)
_raise_on_error(result)
self.progress[mid] = topic
self.topics[topic] = None
_raise_on_error(result)
self.progress[mid] = topic
self.topics[topic] = None
@asyncio.coroutine
def async_unsubscribe(self, topic):