diff options
Diffstat (limited to 'kombu/transport/SLMQ.py')
| -rw-r--r-- | kombu/transport/SLMQ.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kombu/transport/SLMQ.py b/kombu/transport/SLMQ.py index 0a79deec..d6589f66 100644 --- a/kombu/transport/SLMQ.py +++ b/kombu/transport/SLMQ.py @@ -16,7 +16,7 @@ import os from kombu.five import Empty, text_t from kombu.utils import cached_property # , uuid -from kombu.utils.encoding import safe_str +from kombu.utils.encoding import bytes_to_str, safe_str from . import virtual @@ -96,7 +96,7 @@ class Channel(virtual.Channel): rs = q.pop(1) if rs['items']: m = rs['items'][0] - payload = loads(m['body']) + payload = loads(bytes_to_str(m['body'])) if queue in self._noack_queues: q.message(m['id']).delete() else: |