diff --git a/fbchat/_mqtt.py b/fbchat/_mqtt.py index cc9ad06..a9f6e31 100644 --- a/fbchat/_mqtt.py +++ b/fbchat/_mqtt.py @@ -74,8 +74,8 @@ class Mqtt(object): def _on_message_handler(self, client, userdata, message): # Parse payload JSON try: - j = _util.parse_json(message.payload) - except _exception.FBchatFacebookError: + j = _util.parse_json(message.payload.decode("utf-8")) + except (_exception.FBchatFacebookError, UnicodeDecodeError): log.exception("Failed parsing MQTT data on %s as JSON", message.topic) return