diff options
Diffstat (limited to 'cpp/src/qpid/ha/ConnectionObserver.cpp')
| -rw-r--r-- | cpp/src/qpid/ha/ConnectionObserver.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/qpid/ha/ConnectionObserver.cpp b/cpp/src/qpid/ha/ConnectionObserver.cpp index 76be46a92b..66e841e988 100644 --- a/cpp/src/qpid/ha/ConnectionObserver.cpp +++ b/cpp/src/qpid/ha/ConnectionObserver.cpp @@ -65,6 +65,11 @@ ConnectionObserver::ObserverPtr ConnectionObserver::getObserver() { return observer; } +void ConnectionObserver::reset() { + sys::Mutex::ScopedLock l(lock); + observer.reset(); +} + bool ConnectionObserver::isSelf(const broker::Connection& connection) { BrokerInfo info; return getBrokerInfo(connection, info) && info.getSystemId() == self; |