svn commit: r580123 - /incubator/qpid/trunk/qpid/python/qpid/peer.py

[rh...@apache.org]

Author: rhs
Date: Thu Sep 27 11:57:22 2007
New Revision: 580123

URL: http://svn.apache.org/viewvc?rev=580123&view=rev
Log:
issue execution_sync rather than execution_flush prior to waiting for completion

Modified:
    incubator/qpid/trunk/qpid/python/qpid/peer.py

Modified: incubator/qpid/trunk/qpid/python/qpid/peer.py
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/qpid/peer.py?rev=580123&r1=580122&r2=580123&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/qpid/peer.py (original)
+++ incubator/qpid/trunk/qpid/python/qpid/peer.py Thu Sep 27 11:57:22 2007
@@ -281,7 +281,7 @@
     self.request(frame, self.queue_response, content)
     if not frame.method.responses:
       if self.use_execution_layer and frame.method_type.is_l4_command():
-        self.execution_flush()
+        self.execution_sync()
         self.completion.wait()
         if self.closed:
           raise Closed(self.reason)
@@ -335,12 +335,12 @@
           return future
       elif self.synchronous and not frame.method.response \
                and self.use_execution_layer and frame.method.is_l4_command():
-        self.execution_flush()
+        self.execution_sync()
         completed = self.completion.wait(timeout=10)
         if self.closed:
           raise Closed(self.reason)
         if not completed:
-          self.close("Timed-out waiting for completion")
+          self.close("Timed-out waiting for completion of %s" % frame)
     except QueueClosed, e:
       if self.closed:
         raise Closed(self.reason)