qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cctriel...@apache.org
Subject svn commit: r557047 - /incubator/qpid/trunk/qpid/python/tests_0-9/basic.py
Date Tue, 17 Jul 2007 20:28:50 GMT
Author: cctrieloff
Date: Tue Jul 17 13:28:47 2007
New Revision: 557047

URL: http://svn.apache.org/viewvc?view=rev&rev=557047
Log:

cancel test assumes threading model -- added sleep, once we move to 0-10 should wait
for publish ack


Modified:
    incubator/qpid/trunk/qpid/python/tests_0-9/basic.py

Modified: incubator/qpid/trunk/qpid/python/tests_0-9/basic.py
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/tests_0-9/basic.py?view=diff&rev=557047&r1=557046&r2=557047
==============================================================================
--- incubator/qpid/trunk/qpid/python/tests_0-9/basic.py (original)
+++ incubator/qpid/trunk/qpid/python/tests_0-9/basic.py Tue Jul 17 13:28:47 2007
@@ -125,12 +125,12 @@
         channel.queue_declare(queue="test-queue-4", exclusive=True)
         channel.basic_consume(consumer_tag="my-consumer", queue="test-queue-4")
         channel.basic_publish(routing_key="test-queue-4", content=Content("One"))
-
+ 	import time; time.sleep(5) # this should be replace waiting for confirm of publish once
we have message class
         #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)
+        msg = myqueue.get(timeout=5)
         self.assertEqual("One", msg.content.body)
         try:
             msg = myqueue.get(timeout=1) 



Mime
View raw message