Redis: Use super._restore when ack_emulation disabled. Closes celery/celery#1776

1 files changed, 2 insertions, 0 deletions

diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py
index c3f6decd..8d13f36c 100644
--- a/kombu/transport/redis.py
+++ b/kombu/transport/redis.py
@@ -475,6 +475,8 @@ class Channel(virtual.Channel):
                 crit('Could not restore message: %r', payload, exc_info=True)
 
     def _restore(self, message, leftmost=False):
+        if not self.ack_emulation:
+            return super(Channel, self)._restore(message)
         tag = message.delivery_tag
         with self.conn_or_acquire() as client:
             P, _ = client.pipeline() \