change priority to use zpriority and change default priority to +inf

README.md

@@ -7,3 +7,11 @@ Kombu Transport using Redis SortedSets
 ## Running tests
 
     python setup.py test
+
+## Using with celery tasks - zpriority
+
+    task.apply_async(zpriority=10)
+
+zpriority is used not avoid confusion with other celery priority implementations
+
+Note - tasks created using this backend will have the lowest priority, +inf

kombu_redis_priority/transport/redis_priority_async.py

@@ -302,6 +302,8 @@ class Channel(virtual.Channel):
          'priority_steps')  # <-- do not add comma here!
     )
 
+    default_priority = '+inf'
+
     connection_class = redis.Connection if redis else None
 
     def __init__(self, *args, **kwargs):
@@ -852,15 +854,18 @@ def active_queues(self):
                 if queue not in self.active_fanout_queues}
 
     def _get_message_priority(self, message, reverse=False):
-        """Get priority from message.
+        """Get priority from message key zpriority
+
+        Uses zpriority instead of priority to differentiate
+        from other celery priority implementations
 
         The value is not limited!
 
         Note:
             Lower value has more priority.
         """
         try:
-            priority = int(message['properties']['priority'])
+            priority = int(message['properties']['zpriority'])
         except (TypeError, ValueError, KeyError):
             priority = self.default_priority
 

tests/test_sortedset_transport.py

@@ -48,14 +48,14 @@ def test_default_message_add(self):
 
         # verify message:
         # - a time prefix is appended to the message
-        # - has default priority (0)
+        # - has default priority of +inf
         enqueued_msg, priority = next(six.iteritems(raw_queue))
         self.assertEqual(enqueued_msg, self._prefixed_message(faketime, {}))
-        self.assertEqual(priority, 0.0)
+        self.assertEqual(priority, float('+inf'))
 
     def test_prioritized_message_add(self):
         raw_db = self.faker._db
-        msg = {'properties': {'priority': 5}}
+        msg = {'properties': {'zpriority': 5}}
 
         # assert no queues exist
         self.assertEqual(len(raw_db), 0)