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

Tests passing

This commit is contained in:
Ask Solem 2014-02-21 15:06:06 +00:00
parent c3a22adfb4
commit e37467a471
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -225,6 +225,7 @@ class test_Channel(Case):
self.channel = self.connection.default_channel
def create_connection(self, **kwargs):
kwargs.setdefault('transport_options', {'fanout_patterns': True})
return Connection(transport=Transport, **kwargs)
def _get_one_delivery_tag(self, n='test_uniq_tag'):

6
kombu/tests/transport/virtual/test_exchange.py
View File

@ -54,8 +54,10 @@ class test_Fanout(ExchangeCase):
self.e.channel.supports_fanout = True
message = Mock()
self.e.deliver(message, 'exchange', None)
self.e.channel._put_fanout.assert_called_with('exchange', message)
self.e.deliver(message, 'exchange', 'rkey')
self.e.channel._put_fanout.assert_called_with(
'exchange', message, 'rkey',
)
def test_deliver_when_fanout_unsupported(self):
self.e.channel = Mock()