diff options
Diffstat (limited to 'cpp/src/qpid/cluster/Connection.cpp')
| -rw-r--r-- | cpp/src/qpid/cluster/Connection.cpp | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/cpp/src/qpid/cluster/Connection.cpp b/cpp/src/qpid/cluster/Connection.cpp index 17fcf6deb5..88a2806877 100644 --- a/cpp/src/qpid/cluster/Connection.cpp +++ b/cpp/src/qpid/cluster/Connection.cpp @@ -738,8 +738,13 @@ void Connection::sessionError(uint16_t , const std::string& msg) { void Connection::connectionError(const std::string& msg) { // Ignore errors before isOpen(), we're not multicasting yet. - if (connection->isOpen()) + if (connection->isOpen()) { cluster.flagError(*this, ERROR_TYPE_CONNECTION, msg); + } + else + if ( connection->securityFailure() ) { + cluster.eraseLocal(self); + } } void Connection::addQueueListener(const std::string& q, uint32_t listener) { |