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)
