Author: gsim
Date: Mon Feb 5 07:49:00 2007
New Revision: 503731
URL: http://svn.apache.org/viewvc?view=rev&rev=503731
Log:
Fix for handling of header and content frames following a basic.get_ok response.
Modified:
incubator/qpid/branches/qpid.0-9/python/qpid/peer.py
Modified: incubator/qpid/branches/qpid.0-9/python/qpid/peer.py
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/python/qpid/peer.py?view=diff&rev=503731&r1=503730&r2=503731
==============================================================================
--- incubator/qpid/branches/qpid.0-9/python/qpid/peer.py (original)
+++ incubator/qpid/branches/qpid.0-9/python/qpid/peer.py Mon Feb 5 07:49:00
2007
@@ -220,6 +220,8 @@
work.put(self.incoming)
elif isinstance(frame, Response):
self.requester.receive(self, frame)
+ if frame.method_type.content:
+ self.queue = self.responses
return
self.queue.put(frame)
@@ -241,7 +243,11 @@
return None
try:
resp = self.responses.get()
- return Message(self, resp)
+ if resp.method_type.content:
+ return Message(self, resp, read_content(self.responses))
+ else:
+ return Message(self, resp)
+
except QueueClosed, e:
if self.closed:
raise Closed(self.reason)
