diff --git a/platypush/plugins/mqtt/__init__.py b/platypush/plugins/mqtt/__init__.py
index 2ba0e394..a40c6253 100644
--- a/platypush/plugins/mqtt/__init__.py
+++ b/platypush/plugins/mqtt/__init__.py
@@ -137,7 +137,7 @@ class MqttPlugin(RunnablePlugin):
         self.client_id = client_id or str(Config.get('device_id'))
         self.run_topic = (
             f'{run_topic_prefix}/{Config.get("device_id")}'
-            if run_topic_prefix
+            if type(self) == MqttPlugin and run_topic_prefix
             else None
         )