Fix to close connection when issuing a connection exception (ideally would wait a short while before doing so, but this is better than nothing for now).

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

1 files changed, 2 insertions, 0 deletions

diff --git a/cpp/lib/broker/BrokerChannel.cpp b/cpp/lib/broker/BrokerChannel.cpp
index cae48273ff..0d867d0cf3 100644
--- a/cpp/lib/broker/BrokerChannel.cpp
+++ b/cpp/lib/broker/BrokerChannel.cpp
@@ -330,10 +330,12 @@ void Channel::handleMethodInContext(
         connection.client->getConnection().close(
             context, e.code, e.toString(),
             method->amqpClassId(), method->amqpMethodId());
+        connection.getOutput().close();
     }catch(std::exception& e){
         connection.client->getConnection().close(
             context, 541/*internal error*/, e.what(),
             method->amqpClassId(), method->amqpMethodId());
+        connection.getOutput().close();
     }
 }