diff options
Diffstat (limited to 'cpp/src/qpid/broker/SessionHandler.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/SessionHandler.cpp | 6 |
1 files changed, 0 insertions, 6 deletions
diff --git a/cpp/src/qpid/broker/SessionHandler.cpp b/cpp/src/qpid/broker/SessionHandler.cpp index a6b008647f..28827ccb9e 100644 --- a/cpp/src/qpid/broker/SessionHandler.cpp +++ b/cpp/src/qpid/broker/SessionHandler.cpp @@ -44,8 +44,6 @@ void SessionHandler::connectionException( framing::connection::CloseCode code, const std::string& msg) { // NOTE: must tell the error listener _before_ calling connection.close() - if (connection.getErrorListener()) - connection.getErrorListener()->connectionError(msg); if (errorListener) errorListener->connectionException(code, msg); connection.close(code, msg); @@ -54,8 +52,6 @@ void SessionHandler::connectionException( void SessionHandler::channelException( framing::session::DetachCode code, const std::string& msg) { - if (connection.getErrorListener()) - connection.getErrorListener()->sessionError(getChannel(), msg); if (errorListener) errorListener->channelException(code, msg); } @@ -63,8 +59,6 @@ void SessionHandler::channelException( void SessionHandler::executionException( framing::execution::ErrorCode code, const std::string& msg) { - if (connection.getErrorListener()) - connection.getErrorListener()->sessionError(getChannel(), msg); if (errorListener) errorListener->executionException(code, msg); } |
