diff options
Diffstat (limited to 'cpp/src/qpid/client/SubscriptionManagerImpl.cpp')
| -rw-r--r-- | cpp/src/qpid/client/SubscriptionManagerImpl.cpp | 10 |
1 files changed, 10 insertions, 0 deletions
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) { |