diff options
author | Gordon Sim <gsim@apache.org> | 2008-03-05 19:56:43 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2008-03-05 19:56:43 +0000 |
commit | 7e162fa97ef0d430714b9630121a055fe5adece9 (patch) | |
tree | 3e0a99d34d9718837a44802683f7fe6f49785613 /cpp/src/qpid/broker/SessionHandler.cpp | |
parent | 86779be122dea590bc1e5201c58777ea3e362a95 (diff) | |
download | qpid-python-7e162fa97ef0d430714b9630121a055fe5adece9.tar.gz |
forked python tests for 0-10 preview and 0-10 final
fixed result handling in c++ broker
modified testlib in python to allow new 0-10 client to be run as well
converted query tests for final 0-10
added python tests for 0-10 final to automated set for c++ broker (most unconverted still)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@634003 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/SessionHandler.cpp')
-rw-r--r-- | cpp/src/qpid/broker/SessionHandler.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/cpp/src/qpid/broker/SessionHandler.cpp b/cpp/src/qpid/broker/SessionHandler.cpp index 919a3e6ee8..3baa3a89a7 100644 --- a/cpp/src/qpid/broker/SessionHandler.cpp +++ b/cpp/src/qpid/broker/SessionHandler.cpp @@ -69,12 +69,6 @@ void SessionHandler::handleIn(AMQFrame& f) { QPID_MSG("Channel " << channel.get() << " is not open")); } } - } catch(const ChannelException& e) { - ignoring=true; // Ignore trailing frames sent by client. - session->detach(); - session.reset(); - //TODO: implement new exception handling mechanism - //peerSession.closed(e.code, e.what()); }catch(const ConnectionException& e){ connection.close(e.code, e.what(), classId(m), methodId(m)); }catch(const std::exception& e){ @@ -83,6 +77,12 @@ void SessionHandler::handleIn(AMQFrame& f) { } } +void SessionHandler::destroy() { + ignoring=true; // Ignore trailing frames sent by client. + session->detach(); + session.reset(); +} + void SessionHandler::handleOut(AMQFrame& f) { channel.handle(f); // Send it. if (session->sent(f)) |