diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2008-02-26 15:55:29 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2008-02-26 15:55:29 +0000 |
| commit | 633753111c5bbb3215f19d767bb49bcb9535ae5f (patch) | |
| tree | 8b94779e798229e356624348a4883b4c721930c6 | |
| parent | 0d3a8c857888a307ef52958be2da422bfd412a94 (diff) | |
| download | qpid-python-633753111c5bbb3215f19d767bb49bcb9535ae5f.tar.gz | |
QPID-804 : Fix Java Broker Python test failures
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@631264 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | python/tests/unbind.py | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/python/tests/unbind.py b/python/tests/unbind.py index 712ed55c5f..2ae843a604 100644 --- a/python/tests/unbind.py +++ b/python/tests/unbind.py @@ -39,23 +39,23 @@ class UnbindTests(TestBase): #bind two queues and consume from them channel = self.channel - self.queue_declare(queue="queue-1") - self.queue_declare(queue="queue-2") + self.queue_declare(queue="unbind-queue-1") + self.queue_declare(queue="unbind-queue-2") - channel.basic_consume(queue="queue-1", consumer_tag="queue-1", no_ack=True) - channel.basic_consume(queue="queue-2", consumer_tag="queue-2", no_ack=True) + channel.basic_consume(queue="unbind-queue-1", consumer_tag="unbind-queue-1", no_ack=True) + channel.basic_consume(queue="unbind-queue-2", consumer_tag="unbind-queue-2", no_ack=True) - queue1 = self.client.queue("queue-1") - queue2 = self.client.queue("queue-2") + queue1 = self.client.queue("unbind-queue-1") + queue2 = self.client.queue("unbind-queue-2") - channel.queue_bind(exchange=exchange, queue="queue-1", routing_key=routing_key, arguments=args) - channel.queue_bind(exchange=exchange, queue="queue-2", routing_key=routing_key, arguments=args) + channel.queue_bind(exchange=exchange, queue="unbind-queue-1", routing_key=routing_key, arguments=args) + channel.queue_bind(exchange=exchange, queue="unbind-queue-2", routing_key=routing_key, arguments=args) #send a message that will match both bindings channel.basic_publish(exchange=exchange, routing_key=routing_key, content=Content("one", properties={'headers':headers})) #unbind first queue - channel.queue_unbind(exchange=exchange, queue="queue-1", routing_key=routing_key, arguments=args) + channel.queue_unbind(exchange=exchange, queue="unbind-queue-1", routing_key=routing_key, arguments=args) #send another message channel.basic_publish(exchange=exchange, routing_key=routing_key, content=Content("two", properties={'headers':headers})) |