| |
@@ -165,7 +165,7 @@
|
| |
logging.debug('Message received topic:%s payload:%s', message.topic, message.payload.decode("utf-8"))
|
| |
|
| |
# Or you can customize this to fit your needs
|
| |
- signal = {message.topic: message.payload.decode("utf-8")}
|
| |
+ signal = {message.topic: json.loads(message.payload.decode("utf-8"))}
|
| |
userdata['emit'].message(json.dumps((signal)))
|
| |
|
| |
logging.debug('Sending signal: %s', json.dumps(signal))
|
| |
This is a minor fix the avoids having the json double escaped in the message.