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

Redis: Fixes tests after enabling fanout prefix by default.

This commit is contained in:
Ask Solem 2015-11-02 10:56:13 -08:00
parent 779c3be712
commit 991238c960
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kombu/tests/transport/test_redis.py
View File

@ -440,7 +440,7 @@ class test_Channel(Case):
self.channel._subscribe()
self.assertTrue(self.channel.subclient.psubscribe.called)
s_args, _ = self.channel.subclient.psubscribe.call_args
self.assertItemsEqual(s_args[0], ['a', 'b'])
self.assertItemsEqual(s_args[0], ['/{db}.a', '/{db}.b'])
self.channel.subclient.connection._sock = None
self.channel._subscribe()
@ -559,7 +559,7 @@ class test_Channel(Case):
body = {'hello': 'world'}
self.channel._put_fanout('exchange', body, '')
c.publish.assert_called_with('exchange', dumps(body))
c.publish.assert_called_with('/{db}.exchange', dumps(body))
def test_put_priority(self):
client = self.channel.client = Mock(name='client')