2 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/qpid/sys/rdma/RdmaIO.cpp b/cpp/src/qpid/sys/rdma/RdmaIO.cpp
index c89e0f2126..69776654ef 100644
--- a/cpp/src/qpid/sys/rdma/RdmaIO.cpp
+++ b/cpp/src/qpid/sys/rdma/RdmaIO.cpp
@@ -518,6 +518,10 @@ namespace Rdma {
         handle.startWatch(poller);
     }
 
+    void ConnectionManager::stop() {
+        handle.stopWatch();
+    }
+
     void ConnectionManager::event(DispatchHandle&) {
         connectionEvent(ci);
     }
diff --git a/cpp/src/qpid/sys/rdma/RdmaIO.h b/cpp/src/qpid/sys/rdma/RdmaIO.h
index 72cbac154b..55174ea8a1 100644
--- a/cpp/src/qpid/sys/rdma/RdmaIO.h
+++ b/cpp/src/qpid/sys/rdma/RdmaIO.h
@@ -179,6 +179,7 @@ namespace Rdma {
         virtual ~ConnectionManager();
 
         void start(qpid::sys::Poller::shared_ptr poller, const qpid::sys::SocketAddress& addr);
+        void stop();
 
     private:
         void event(qpid::sys::DispatchHandle& handle);