Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Redis: Fixes priority tests

This commit is contained in:
Ask Solem 2016-12-08 17:06:12 -08:00
parent 9c1044ef3a
commit 1464a2afbe
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
t/unit/transport/test_redis.py
View File

@ -573,19 +573,19 @@ class test_Channel:
self.channel._put('george', msg1) self.channel._put('george', msg1)
client().lpush.assert_called_with( client().lpush.assert_called_with(
self.channel._q_for_pri('george', 6), dumps(msg1), self.channel._q_for_pri('george', 3), dumps(msg1),
) )
msg2 = {'properties': {'priority': 313}} msg2 = {'properties': {'priority': 313}}
self.channel._put('george', msg2) self.channel._put('george', msg2)
client().lpush.assert_called_with( client().lpush.assert_called_with(
self.channel._q_for_pri('george', 0), dumps(msg2), self.channel._q_for_pri('george', 9), dumps(msg2),
) )
msg3 = {'properties': {}} msg3 = {'properties': {}}
self.channel._put('george', msg3) self.channel._put('george', msg3)
client().lpush.assert_called_with( client().lpush.assert_called_with(
self.channel._q_for_pri('george', 9), dumps(msg3), self.channel._q_for_pri('george', 0), dumps(msg3),
) )
def test_delete(self): def test_delete(self):