From 33d02c5cbe67fb113e1b0f3b370dae4e3a211b6d Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Fri, 9 Feb 2007 13:52:00 +0000 Subject: 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 --- cpp/lib/broker/BrokerChannel.cpp | 2 ++ 1 file changed, 2 insertions(+) (limited to 'cpp') 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(); } } -- cgit v1.2.1