diff options
| author | Ask Solem <ask@celeryproject.org> | 2014-01-28 13:53:05 +0000 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2014-01-28 13:53:05 +0000 |
| commit | 4195662901e9164aa7704fa6a5db8ff871502fde (patch) | |
| tree | 43e55ddb01e33c89bcec1a1384a73ef0bbb4a6d9 /kombu/entity.py | |
| parent | 2cac6d09e1085b048054b32cbd3071d4d53592ed (diff) | |
| download | kombu-4195662901e9164aa7704fa6a5db8ff871502fde.tar.gz | |
Message: Handle decompression and postencod errors as decode errors
Diffstat (limited to 'kombu/entity.py')
| -rw-r--r-- | kombu/entity.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kombu/entity.py b/kombu/entity.py index 5bf1470b..fda53bef 100644 --- a/kombu/entity.py +++ b/kombu/entity.py @@ -572,6 +572,8 @@ class Queue(MaybeChannelBound): m2p = getattr(self.channel, 'message_to_python', None) if m2p: message = m2p(message) + if message.errors: + message._reraise_error() message.accept = prepare_accept_content(accept) return message |