You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@qpid.apache.org by gs...@apache.org on 2007/01/24 11:04:32 UTC

svn commit: r499332 - /incubator/qpid/branches/qpid.0-9/cpp/lib/broker/BrokerAdapter.cpp

Author: gsim
Date: Wed Jan 24 02:04:31 2007
New Revision: 499332

URL: http://svn.apache.org/viewvc?view=rev&rev=499332
Log:
Don't close channel on connection (resulting in BrokerAdapter being deleted) until close request has been successfully sent.


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

Modified: incubator/qpid/branches/qpid.0-9/cpp/lib/broker/BrokerAdapter.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/cpp/lib/broker/BrokerAdapter.cpp?view=diff&rev=499332&r1=499331&r2=499332
==============================================================================
--- incubator/qpid/branches/qpid.0-9/cpp/lib/broker/BrokerAdapter.cpp (original)
+++ incubator/qpid/branches/qpid.0-9/cpp/lib/broker/BrokerAdapter.cpp Wed Jan 24 02:04:31 2007
@@ -516,10 +516,10 @@
     try{
         method->invoke(*serverOps, context);
     }catch(ChannelException& e){
-        connection.closeChannel(getId());
         connection.client->getChannel().close(
             context, e.code, e.toString(),
             method->amqpClassId(), method->amqpMethodId());
+        connection.closeChannel(getId());
     }catch(ConnectionException& e){
         connection.client->getConnection().close(
             context, e.code, e.toString(),