From 875e35a15606c41e65b20c62e146cfc2590f1494 Mon Sep 17 00:00:00 2001
From: Keith Wall <kwall@apache.org>
Date: Sat, 6 Sep 2014 22:05:30 +0000
Subject: QPID-6081: [Python Client] 08..091 Ensure that multiframe bodies are
 received correctly

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1622948 13f79535-47bb-0310-9956-ffa450edef68
---
 qpid/python/qpid/peer.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

(limited to 'qpid/python')

diff --git a/qpid/python/qpid/peer.py b/qpid/python/qpid/peer.py
index 95055cc014..40571780f1 100644
--- a/qpid/python/qpid/peer.py
+++ b/qpid/python/qpid/peer.py
@@ -357,12 +357,12 @@ def read_content(queue):
   for i in range(header.weight):
     children.append(read_content(queue))
   buf = StringIO()
-  eof = header.eof
-  while not eof:
+  readbytes = 0
+  while readbytes < header.size:
     body = queue.get()
-    eof = body.eof
     content = body.content
     buf.write(content)
+    readbytes += len(content)
   return Content(buf.getvalue(), children, header.properties.copy())
 
 class Future:
-- 
cgit v1.2.1