diff options
| author | Gordon Sim <gsim@apache.org> | 2007-10-11 13:29:37 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2007-10-11 13:29:37 +0000 |
| commit | 685aad458c485cd260df694f58d2f7641ce94e32 (patch) | |
| tree | 57b4963ac7105f711ced6e4627232e0f62fda3be /python/tests_0-10/alternate-exchange.py | |
| parent | a23f05ddb503e587473519fa3f6491a93798a535 (diff) | |
| download | qpid-python-685aad458c485cd260df694f58d2f7641ce94e32.tar.gz | |
Exclusive no longer implies auto-delete on queue.declare.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@583821 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/tests_0-10/alternate-exchange.py')
| -rw-r--r-- | python/tests_0-10/alternate-exchange.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/python/tests_0-10/alternate-exchange.py b/python/tests_0-10/alternate-exchange.py index a857496a48..83f8d85811 100644 --- a/python/tests_0-10/alternate-exchange.py +++ b/python/tests_0-10/alternate-exchange.py @@ -37,13 +37,13 @@ class AlternateExchangeTests(TestBase): channel.exchange_declare(exchange="primary", type="direct", alternate_exchange="secondary") #declare, bind (to the alternate exchange) and consume from a queue for 'returned' messages - channel.queue_declare(queue="returns", exclusive=True) + channel.queue_declare(queue="returns", exclusive=True, auto_delete=True) channel.queue_bind(queue="returns", exchange="secondary") self.subscribe(destination="a", queue="returns") returned = self.client.queue("a") #declare, bind (to the primary exchange) and consume from a queue for 'processed' messages - channel.queue_declare(queue="processed", exclusive=True) + channel.queue_declare(queue="processed", exclusive=True, auto_delete=True) channel.queue_bind(queue="processed", exchange="primary", routing_key="my-key") self.subscribe(destination="b", queue="processed") processed = self.client.queue("b") @@ -71,7 +71,7 @@ class AlternateExchangeTests(TestBase): channel = self.channel #set up a 'dead letter queue': channel.exchange_declare(exchange="dlq", type="fanout") - channel.queue_declare(queue="deleted", exclusive=True) + channel.queue_declare(queue="deleted", exclusive=True, auto_delete=True) channel.queue_bind(exchange="dlq", queue="deleted") self.subscribe(destination="dlq", queue="deleted") dlq = self.client.queue("dlq") @@ -101,13 +101,13 @@ class AlternateExchangeTests(TestBase): channel = self.channel #set up a 'dead letter queue': channel.exchange_declare(exchange="dlq", type="fanout") - channel.queue_declare(queue="immediate", exclusive=True) + channel.queue_declare(queue="immediate", exclusive=True, auto_delete=True) channel.queue_bind(exchange="dlq", queue="immediate") self.subscribe(destination="dlq", queue="immediate") dlq = self.client.queue("dlq") #create a queue using the dlq as its alternate exchange: - channel.queue_declare(queue="no-consumers", alternate_exchange="dlq", exclusive=True) + channel.queue_declare(queue="no-consumers", alternate_exchange="dlq", exclusive=True, auto_delete=True) #send it some messages: #TODO: WE HAVE LOST THE IMMEDIATE FLAG; FIX THIS ONCE ITS BACK channel.message_transfer(content=Content("no one wants me", properties={'routing_key':"no-consumers"})) @@ -128,7 +128,7 @@ class AlternateExchangeTests(TestBase): """ channel = self.channel channel.exchange_declare(exchange="alternate", type="fanout") - channel.queue_declare(queue="q", exclusive=True, alternate_exchange="alternate") + channel.queue_declare(queue="q", exclusive=True, auto_delete=True, alternate_exchange="alternate") try: channel.exchange_delete(exchange="alternate") self.fail("Expected deletion of in-use alternate-exchange to fail") |
