diff --git a/platypush/backend/mqtt/__init__.py b/platypush/backend/mqtt/__init__.py index edc231ca1..da2aead34 100644 --- a/platypush/backend/mqtt/__init__.py +++ b/platypush/backend/mqtt/__init__.py @@ -296,7 +296,7 @@ class MqttBackend(Backend): self.logger.info('Processing response on the MQTT topic {}: {}'. format(response_topic, response)) - self.send_message(response) + self.send_message(response, topic=response_topic) msg = msg.payload.decode('utf-8') # noinspection PyBroadException