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)