summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2007-07-17 21:19:01 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2007-07-17 21:19:01 +0000
commitfb7be00779dad7d7d56a7d80fce7ecda74ffdd9d (patch)
tree65e6cbb47267b864793ea6d50d040482a20140ee
parent000e147ca5c9253c5ce3ff46d7664e97efdb8479 (diff)
downloadqpid-python-fb7be00779dad7d7d56a7d80fce7ecda74ffdd9d.tar.gz
fix 0-8 cancel test also
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@557058 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--python/tests_0-8/basic.py7
1 files changed, 4 insertions, 3 deletions
diff --git a/python/tests_0-8/basic.py b/python/tests_0-8/basic.py
index 140576540a..95ca0d7287 100644
--- a/python/tests_0-8/basic.py
+++ b/python/tests_0-8/basic.py
@@ -126,12 +126,13 @@ class BasicTests(TestBase):
channel.basic_consume(consumer_tag="my-consumer", queue="test-queue-4")
channel.basic_publish(routing_key="test-queue-4", content=Content("One"))
- #cancel should stop messages being delivered
- channel.basic_cancel(consumer_tag="my-consumer")
- channel.basic_publish(routing_key="test-queue-4", content=Content("Two"))
myqueue = self.client.queue("my-consumer")
msg = myqueue.get(timeout=1)
self.assertEqual("One", msg.content.body)
+
+ #cancel should stop messages being delivered
+ channel.basic_cancel(consumer_tag="my-consumer")
+ channel.basic_publish(routing_key="test-queue-4", content=Content("Two"))
try:
msg = myqueue.get(timeout=1)
self.fail("Got message after cancellation: " + msg)