Psion-fanatic/platypush
1
0
Fork 0
forked from platypush/platypush
Code Pull requests Activity

Don't create an MQTT client connection if there are no topics to subscribe.

Browse source 
If we open multiple connections from multiple MQTT-based backends to the
same host, with some of them having no topics subscribed, Paho-MQTT can
mess up which client is supposed to receive which message and we may end
up with lost messages on the platypush_bus_mqt/<host> topic.
This commit is contained in:
Fabio Manganiello 2021-02-15 22:02:58 +01:00
parent 77c6f699a0
commit ee7407a7cc
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
platypush/backend/mqtt.py
View file

@ -319,8 +319,8 @@ class MqttBackend(Backend):
def run(self): def run(self):
super().run() super().run()
if self.host: if self.host and self.subscribe_default_topic:
topics = [self.topic] if self.subscribe_default_topic else [] topics = [self.topic]
client = self._get_client(host=self.host, port=self.port, topics=topics, username=self.username, client = self._get_client(host=self.host, port=self.port, topics=topics, username=self.username,
password=self.password, client_id=self.client_id, password=self.password, client_id=self.client_id,
tls_cafile=self.tls_cafile, tls_certfile=self.tls_certfile, tls_cafile=self.tls_cafile, tls_certfile=self.tls_certfile,