# HG changeset patch # User drewp # Date 1556694410 25200 # Node ID e121dc5c09df9b308232795ec74565766b6ac3a0 # Parent 19b71e86654ce6322b83435978f57acbd4c5f68a mqtt lib wants to encode topic names Ignore-this: 2b72670ac614943e7188419e1aba93b darcs-hash:59524f522f3e7922db38552ea95978df7254cbb6 diff -r 19b71e86654c -r e121dc5c09df 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