diff options
| author | Ask Solem <ask@celeryproject.org> | 2013-09-09 15:49:44 +0100 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2013-09-09 15:49:44 +0100 |
| commit | 7aa2a9990cef81b4a322991fc5787f86dff484d0 (patch) | |
| tree | 5e6daf9cfb51987c44d5e0a4747c32ed270dc969 /kombu/entity.py | |
| parent | 663b7497facf5dd8b0b888b9dd163bce35ca20cb (diff) | |
| download | kombu-7aa2a9990cef81b4a322991fc5787f86dff484d0.tar.gz | |
Tests passing
Diffstat (limited to 'kombu/entity.py')
| -rw-r--r-- | kombu/entity.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kombu/entity.py b/kombu/entity.py index 72ddb7d2..50e89dc2 100644 --- a/kombu/entity.py +++ b/kombu/entity.py @@ -563,10 +563,10 @@ class Queue(MaybeChannelBound): no_ack = self.no_ack if no_ack is None else no_ack message = self.channel.basic_get(queue=self.name, no_ack=no_ack) if message is not None: - message.accept = prepare_accept_encoding(accept) m2p = getattr(self.channel, 'message_to_python', None) if m2p: message = m2p(message) + message.accept = prepare_accept_encoding(accept) return message def purge(self, nowait=False): |