diff lib/mqtt_client/mqtt_client.py @ 584:8fcd51b1cb00

don't send empty subscribe request at startup- broker will hang up on us Ignore-this: 58121f8153070aeddc3c9957fd8d9006
author drewp@bigasterisk.com
date Fri, 10 May 2019 02:09:23 -0700
parents 6b6a7d06691e
children 3d3ad50e2c51
line wrap: on
line diff
--- a/lib/mqtt_client/mqtt_client.py	Fri May 10 01:32:03 2019 -0700
+++ b/lib/mqtt_client/mqtt_client.py	Fri May 10 02:09:23 2019 -0700
@@ -30,6 +30,8 @@
 
     def _subscribeAll(self):
         topics = list(self.observersByTopic)
+        if not topics:
+            return
         log.info('subscribing %r', topics)
         self.protocol.subscribe(topics=[(topic.decode('utf8'), 2) for topic in topics])