diff options
| author | Gordon Sim <gsim@apache.org> | 2015-01-20 10:00:17 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2015-01-20 10:00:17 +0000 |
| commit | f759ba5b3a919149622c656a2bb06f21d893ac1e (patch) | |
| tree | dc3c672191992f82713c99505051f79a980dc75c /qpid/cpp/src/qpid/amqp_0_10 | |
| parent | b086149e61bfd501f316d5ddb43010506da4e78c (diff) | |
| download | qpid-python-f759ba5b3a919149622c656a2bb06f21d893ac1e.tar.gz | |
QPID-6325: improve 0-10 connection handling logic
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1653216 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qpid/amqp_0_10')
| -rw-r--r-- | qpid/cpp/src/qpid/amqp_0_10/Connection.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/amqp_0_10/Connection.cpp b/qpid/cpp/src/qpid/amqp_0_10/Connection.cpp index 87085b6d77..866f98071b 100644 --- a/qpid/cpp/src/qpid/amqp_0_10/Connection.cpp +++ b/qpid/cpp/src/qpid/amqp_0_10/Connection.cpp @@ -54,7 +54,7 @@ size_t Connection::decode(const char* buffer, size_t size) { } } framing::AMQFrame frame; - while(frame.decode(in)) { + while(!pushClosed && frame.decode(in)) { QPID_LOG(trace, "RECV [" << identifier << "]: " << frame); connection->received(frame); } |