svn commit: r505291 - /incubator/qpid/branches/qpid.0-9/cpp/lib/broker/BrokerChannel.cpp

[gsim]

Author: gsim
Date: Fri Feb  9 05:52:00 2007
New Revision: 505291

URL: http://svn.apache.org/viewvc?view=rev&rev=505291
Log:
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).


Modified:
    incubator/qpid/branches/qpid.0-9/cpp/lib/broker/BrokerChannel.cpp

Modified: incubator/qpid/branches/qpid.0-9/cpp/lib/broker/BrokerChannel.cpp
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/cpp/lib/broker/BrokerChannel.cpp?view=diff&rev=505291&r1=505290&r2=505291
==============================================================================
--- incubator/qpid/branches/qpid.0-9/cpp/lib/broker/BrokerChannel.cpp (original)
+++ incubator/qpid/branches/qpid.0-9/cpp/lib/broker/BrokerChannel.cpp Fri Feb  
9 05:52:00 2007
@@ -330,10 +330,12 @@
         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();
     }
 }