diff options
Diffstat (limited to 'qpid/cpp/src/qpid/ha/ConnectionExcluder.cpp')
| -rw-r--r-- | qpid/cpp/src/qpid/ha/ConnectionExcluder.cpp | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/ha/ConnectionExcluder.cpp b/qpid/cpp/src/qpid/ha/ConnectionExcluder.cpp index df50f1da19..67ad7202d6 100644 --- a/qpid/cpp/src/qpid/ha/ConnectionExcluder.cpp +++ b/qpid/cpp/src/qpid/ha/ConnectionExcluder.cpp @@ -27,11 +27,10 @@ namespace qpid { namespace ha { -ConnectionExcluder::ConnectionExcluder(PrimaryTest isPrimary_) : isPrimary(isPrimary_) {} +ConnectionExcluder::ConnectionExcluder() {} void ConnectionExcluder::opened(broker::Connection& connection) { - if (!isPrimary() && !connection.isLink() - && !connection.getClientProperties().isSet(ADMIN_TAG)) + if (!connection.isLink() && !connection.getClientProperties().isSet(ADMIN_TAG)) throw Exception( QPID_MSG("HA: Backup broker rejected connection " << connection.getMgmtId())); } |