diff --git a/platypush/backend/mqtt.py b/platypush/backend/mqtt.py
index d31cec9c1..899897d4b 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()