You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by cc...@apache.org on 2007/07/17 23:19:04 UTC
svn commit: r557058 - /incubator/qpid/trunk/qpid/python/tests_0-8/basic.py
Author: cctrieloff
Date: Tue Jul 17 14:19:01 2007
New Revision: 557058
URL: http://svn.apache.org/viewvc?view=rev&rev=557058
Log:
fix 0-8 cancel test also
Modified:
incubator/qpid/trunk/qpid/python/tests_0-8/basic.py
Modified: incubator/qpid/trunk/qpid/python/tests_0-8/basic.py
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/tests_0-8/basic.py?view=diff&rev=557058&r1=557057&r2=557058
==============================================================================
--- incubator/qpid/trunk/qpid/python/tests_0-8/basic.py (original)
+++ incubator/qpid/trunk/qpid/python/tests_0-8/basic.py Tue Jul 17 14:19:01 2007
@@ -126,12 +126,13 @@
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)