From e37467a4715dacf87c4916fa3a65b5052da5d6f4 Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Fri, 21 Feb 2014 15:06:06 +0000 Subject: [PATCH] Tests passing --- kombu/tests/transport/test_redis.py | 1 + kombu/tests/transport/virtual/test_exchange.py | 6 ++++-- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/kombu/tests/transport/test_redis.py b/kombu/tests/transport/test_redis.py index 75b4bdca..9b5da64a 100644 --- a/kombu/tests/transport/test_redis.py +++ b/kombu/tests/transport/test_redis.py @@ -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'): diff --git a/kombu/tests/transport/virtual/test_exchange.py b/kombu/tests/transport/virtual/test_exchange.py index e32b1fc1..ad590afc 100644 --- a/kombu/tests/transport/virtual/test_exchange.py +++ b/kombu/tests/transport/virtual/test_exchange.py @@ -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()