MQTT backend should call on_message instead of posting directly to the bus

2018-09-24 23:21:02 +02:00 · 2018-09-24 23:21:02 +02:00 · 65ec2458d8
commit 65ec2458d8
parent d215410a6a
1 changed files with 1 additions and 1 deletions
--- 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()