From 099e4d88508acfbd403dfefe27ede73f1ee67fe0 Mon Sep 17 00:00:00 2001
From: Gordon Sim <gsim@apache.org>
Date: Mon, 9 Jul 2012 12:13:52 +0000
Subject: QPID-3757: clean up demux when subscription manager is destroyed

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1359099 13f79535-47bb-0310-9956-ffa450edef68
---
 cpp/src/qpid/client/SubscriptionManagerImpl.cpp | 10 ++++++++++
 1 file changed, 10 insertions(+)

(limited to 'cpp/src/qpid/client/SubscriptionManagerImpl.cpp')

diff --git a/cpp/src/qpid/client/SubscriptionManagerImpl.cpp b/cpp/src/qpid/client/SubscriptionManagerImpl.cpp
index a558d90be8..7dead112e5 100644
--- a/cpp/src/qpid/client/SubscriptionManagerImpl.cpp
+++ b/cpp/src/qpid/client/SubscriptionManagerImpl.cpp
@@ -39,6 +39,16 @@ SubscriptionManagerImpl::SubscriptionManagerImpl(const Session& s)
   : dispatcher(s), session(s), autoStop(true)
 {}
 
+SubscriptionManagerImpl::~SubscriptionManagerImpl()
+{
+    sys::Mutex::ScopedLock l(lock);
+    for (std::map<std::string, Subscription>::iterator i = subscriptions.begin(); i != subscriptions.end(); ++i) {
+        boost::intrusive_ptr<SubscriptionImpl> s = PrivateImplRef<Subscription>::get(i->second);
+        if (s) s->cancelDiversion();
+    }
+    subscriptions.clear();
+}
+
 Subscription SubscriptionManagerImpl::subscribe(
     MessageListener& listener, const std::string& q, const SubscriptionSettings& ss, const std::string& n)
 {
-- 
cgit v1.2.1