Author: gsim
Date: Tue Mar 1 16:56:28 2011
New Revision: 1075915
URL: http://svn.apache.org/viewvc?rev=1075915&view=rev
Log:
QPID-3087: use unique session name to avoid race where it collides with the
detaching session that generated the exception
Modified:
qpid/trunk/qpid/tests/src/py/qpid_tests/broker_0_10/extensions.py
Modified: qpid/trunk/qpid/tests/src/py/qpid_tests/broker_0_10/extensions.py
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/tests/src/py/qpid_tests/broker_0_10/extensions.py?rev=1075915&r1=1075914&r2=1075915&view=diff
==============================================================================
--- qpid/trunk/qpid/tests/src/py/qpid_tests/broker_0_10/extensions.py (original)
+++ qpid/trunk/qpid/tests/src/py/qpid_tests/broker_0_10/extensions.py Tue Mar
1 16:56:28 2011
@@ -21,6 +21,7 @@ from qpid.queue import Empty
from qpid.content import Content
from qpid.testlib import TestBase010
from qpid.session import SessionException
+from qpid.datatypes import uuid4
from time import sleep
class ExtensionTests(TestBase010):
@@ -52,10 +53,10 @@ class ExtensionTests(TestBase010):
for i in range(1, 3):
try:
self.session.queue_declare(queue=name, arguments=args)
- #self.session.queue_delete(queue=name) # cleanup
+ self.session.queue_delete(queue=name) # cleanup
self.fail("declare with invalid policy args suceeded: %s
(iteration %d)" % (args, i))
except SessionException, e:
- self.session = self.conn.session("replacement", 2)
+ self.session = self.conn.session(str(uuid4()))
def test_policy_max_size_as_valid_string(self):
self.valid_policy_args({"qpid.max_size":"3"})
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
