diff --git a/carrot/messaging.py b/carrot/messaging.py index 114233a..97712b7 100644 --- a/carrot/messaging.py +++ b/carrot/messaging.py @@ -664,9 +664,9 @@ def declare(self): """ self.backend.exchange_declare(exchange=self.exchange, - type=self.exchange_type, - durable=self.durable, - auto_delete=self.auto_delete) + type=self.exchange_type, + durable=self.durable, + auto_delete=self.auto_delete) def __enter__(self): return self diff --git a/tests/backend.py b/tests/backend.py index e37940e..07ce19d 100644 --- a/tests/backend.py +++ b/tests/backend.py @@ -39,7 +39,7 @@ def setUp(self): def create_consumer(self, **options): queue = "%s%s" % (self.queue, self.nextq()) return Consumer(connection=self.conn, - queue=queue, exchange=self.exchange + str(self.nextq), + queue=queue, exchange=self.exchange, routing_key=self.routing_key, **options) def create_consumerset(self, queues={}, consumers=[], **options): @@ -54,11 +54,12 @@ def create_publisher(self, exchange=None, routing_key=None, **options): **options) def test_regression_implied_auto_delete(self): - consumer = self.create_consumer(exclusive=True) + consumer = self.create_consumer(exclusive=True, auto_declare=False) self.assertTrue(consumer.auto_delete, "exclusive implies auto_delete") consumer.close() - consumer = self.create_consumer(durable=True, auto_delete=False) + consumer = self.create_consumer(durable=True, auto_delete=False, + auto_declare=False) self.assertFalse(consumer.auto_delete, """durable does *not* imply auto_delete. regression: http://github.com/ask/carrot/issues/closed#issue/2""")