Merge pull request #244 from Necroneco/mqtt-message-async

Author: niceboygithub

custom_components/aqara_gateway/core/gateway.py

@@ -491,6 +491,9 @@ def on_disconnect(self, client, userdata, ret):
         self.hass.create_task(self.async_run())
 
     def on_message(self, client: Client, userdata, msg: MQTTMessage):
+        self.hass.loop.call_soon_threadsafe(self._on_message, msg)
+
+    def _on_message(self, msg: MQTTMessage):
         # pylint: disable=unused-argument
         """ on getting messages from mqtt server """