diff options
author | Gordon Sim <gsim@apache.org> | 2007-01-24 10:04:31 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2007-01-24 10:04:31 +0000 |
commit | 39fd53bc06f35d1f29becdb993f7bbdffc361cda (patch) | |
tree | a8df02f23c123aedc50281f46369e7962b7b1231 | |
parent | 8b82eb63a9af8c64230797002a28435aee99d110 (diff) | |
download | qpid-python-39fd53bc06f35d1f29becdb993f7bbdffc361cda.tar.gz |
Don't close channel on connection (resulting in BrokerAdapter being deleted) until close request has been successfully sent.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499332 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r-- | cpp/lib/broker/BrokerAdapter.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cpp/lib/broker/BrokerAdapter.cpp b/cpp/lib/broker/BrokerAdapter.cpp index fda7d15784..585be5f79d 100644 --- a/cpp/lib/broker/BrokerAdapter.cpp +++ b/cpp/lib/broker/BrokerAdapter.cpp @@ -516,10 +516,10 @@ void BrokerAdapter::handleMethodInContext( 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(), |