diff --git a/kombu/serialization.py b/kombu/serialization.py index 54da27cf..29542515 100644 --- a/kombu/serialization.py +++ b/kombu/serialization.py @@ -286,9 +286,9 @@ def register_json(): from anyjson import loads, dumps def _loads(obj): - if isinstance(obj, buffer): - obj = str(obj) - return loads(bytes_to_str(obj)) + if isinstance(obj, str): + obj = bytes_to_str(obj) + return loads(obj) registry.register('json', dumps, _loads, content_type='application/json',