From 65ec2458d8704f92bf87d87f055b4fc2e4365171 Mon Sep 17 00:00:00 2001 From: Fabio Manganiello Date: Mon, 24 Sep 2018 23:21:02 +0200 Subject: [PATCH] MQTT backend should call on_message instead of posting directly to the bus --- platypush/backend/mqtt.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/platypush/backend/mqtt.py b/platypush/backend/mqtt.py index d31cec9c14..899897d4b3 100644 --- a/platypush/backend/mqtt.py +++ b/platypush/backend/mqtt.py @@ -55,7 +55,7 @@ class MqttBackend(Backend): except: pass self.logger.info('Received message on the MQTT backend: {}'.format(msg)) - self.bus.post(msg) + self.on_message(msg) super().run() client = mqtt.Client()