From 9c1044ef3a55128ed25053bd75981454b4ae8f3c Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Thu, 8 Dec 2016 17:04:52 -0800 Subject: [PATCH] Redis: Do not reverse message priority --- kombu/transport/redis.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py index e6abec19..4bd47d72 100644 --- a/kombu/transport/redis.py +++ b/kombu/transport/redis.py @@ -761,7 +761,7 @@ class Channel(virtual.Channel): def _put(self, queue, message, **kwargs): """Deliver message.""" - pri = self._get_message_priority(message, reverse=True) + pri = self._get_message_priority(message, reverse=False) with self.conn_or_acquire() as client: client.lpush(self._q_for_pri(queue, pri), dumps(message))