* qpid/peer.py - fix to prevent race between handling of connection.close request and socket close

* qpid/testlib.py - close client (if not closed) on tearDown
* tests/basic.py - revert back to using exclusive queue which should now be cleaned up on tear down
* tests/message.py - fix to prefetch tests



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@505287 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 4 insertions, 5 deletions

diff --git a/python/tests/message.py b/python/tests/message.py
index 3c52c2d03c..df621ff295 100644
--- a/python/tests/message.py
+++ b/python/tests/message.py
@@ -277,7 +277,7 @@ class MessageTests(TestBase):
         #todo: once batching is implmented, send a single response for all messages
         for msg in msgs:
             msg.ok()
-        del msgs    
+        msgs = []    
 
         for i in range(6, 11):
             msg = queue.get(timeout=1)
@@ -286,7 +286,7 @@ class MessageTests(TestBase):
 
         for msg in msgs:
             msg.ok()
-        del msgs    
+        msgs = []    
 
         try:
             extra = queue.get(timeout=1)
@@ -317,7 +317,6 @@ class MessageTests(TestBase):
         for i in range(1, 6):
             msg = queue.get(timeout=1)
             self.assertEqual("Message %d" % i, msg.body)
-            print "Got Message %d" % i
             msgs.append(msg)
 
         try:
@@ -328,7 +327,7 @@ class MessageTests(TestBase):
         #ack messages and check that the next set arrive ok:
         for msg in msgs:
             msg.ok()
-        del msgs    
+        msgs = []    
 
         for i in range(6, 11):
             msg = queue.get(timeout=1)
@@ -337,7 +336,7 @@ class MessageTests(TestBase):
 
         for msg in msgs:
             msg.ok()
-        del msgs    
+        msgs = []    
 
         try:
             extra = queue.get(timeout=1)