# HG changeset patch # User drewp@bigasterisk.com # Date 1556694410 25200 # Node ID 1df51216b71229448f8f3161b5d27eb69f0efa57 # Parent 80f3cdc58224aaba1f1d31daf69d30cea126fac4 mqtt lib wants to encode topic names Ignore-this: 2b72670ac614943e7188419e1aba93b diff -r 80f3cdc58224 -r 1df51216b712 lib/mqtt_client/mqtt_client.py --- a/lib/mqtt_client/mqtt_client.py Wed May 01 00:03:23 2019 -0700 +++ b/lib/mqtt_client/mqtt_client.py Wed May 01 00:06:50 2019 -0700 @@ -78,10 +78,10 @@ self._resubscribe(topic) return ret - def _resubscribe(self, topic): + def _resubscribe(self, topic: bytes): log.info('subscribing %r', topic) self.serv.protocol.onPublish = self._onPublish - return self.serv.protocol.subscribe(topics=[(topic, 2)]) + return self.serv.protocol.subscribe(topics=[(topic.decode('utf-8'), 2)]) def _observe_msgs(self, observer): self.obs = observer