diff options
| author | Ask Solem <ask@celeryproject.org> | 2014-02-21 15:06:06 +0000 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2014-02-21 15:06:06 +0000 |
| commit | e37467a4715dacf87c4916fa3a65b5052da5d6f4 (patch) | |
| tree | 5a5246cda485d714f3d7266853b7abda29e8b2dd | |
| parent | c3a22adfb422ea60869322a973357c1123c10949 (diff) | |
| download | kombu-e37467a4715dacf87c4916fa3a65b5052da5d6f4.tar.gz | |
Tests passing
| -rw-r--r-- | kombu/tests/transport/test_redis.py | 1 | ||||
| -rw-r--r-- | 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() |