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

Fix MQTT async_added_to_hass (#18575)

Browse Source 
* Fix some invocations

* Update manual_mqtt.py
This commit is contained in:
Paulus Schoutsen 2018-11-19 20:48:26 +01:00 committed by Pascal Vizeli
parent 3891f2eebe
commit f86083cf52
2 changed files with 5 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
homeassistant/components/alarm_control_panel/manual_mqtt.py
View File

@ -335,11 +335,8 @@ class ManualMQTTAlarm(alarm.AlarmControlPanel):
return state_attr return state_attr
def async_added_to_hass(self): async def async_added_to_hass(self):
"""Subscribe to MQTT events. """Subscribe to MQTT events."""
This method must be run in the event loop and returns a coroutine.
"""
async_track_state_change( async_track_state_change(
self.hass, self.entity_id, self._async_state_changed_listener self.hass, self.entity_id, self._async_state_changed_listener
) )
@ -359,7 +356,7 @@ class ManualMQTTAlarm(alarm.AlarmControlPanel):
_LOGGER.warning("Received unexpected payload: %s", payload) _LOGGER.warning("Received unexpected payload: %s", payload)
return return
return mqtt.async_subscribe( await mqtt.async_subscribe(
self.hass, self._command_topic, message_received, self._qos) self.hass, self._command_topic, message_received, self._qos)
async def _async_state_changed_listener(self, entity_id, old_state, async def _async_state_changed_listener(self, entity_id, old_state,

5
homeassistant/components/camera/mqtt.py
View File

@ -89,13 +89,12 @@ class MqttCamera(Camera):
"""Return a unique ID.""" """Return a unique ID."""
return self._unique_id return self._unique_id
@asyncio.coroutine async def async_added_to_hass(self):
def async_added_to_hass(self):
"""Subscribe MQTT events.""" """Subscribe MQTT events."""
@callback @callback
def message_received(topic, payload, qos): def message_received(topic, payload, qos):
"""Handle new MQTT messages.""" """Handle new MQTT messages."""
self._last_image = payload self._last_image = payload
return mqtt.async_subscribe( await mqtt.async_subscribe(
self.hass, self._topic, message_received, self._qos, None) self.hass, self._topic, message_received, self._qos, None)