diff options
author | Gordon Sim <gsim@apache.org> | 2008-11-06 10:47:57 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2008-11-06 10:47:57 +0000 |
commit | 92914dcf983f5328a19648950ab8d2c42ca77925 (patch) | |
tree | 179a813bc70cfdf6ffb7affd4d5cdee5c472a2f9 /cpp/src/qpid/client/SubscriptionManager.cpp | |
parent | 3cb32fb199ccf271da1c08f355940c2550d48464 (diff) | |
download | qpid-python-92914dcf983f5328a19648950ab8d2c42ca77925.tar.gz |
SubscriptionManager and Dispatcher were missing wait() methods meaning that if start was called there was no way to join with the dispatch thread and shutdown cleanly. Fixed by adding that method.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711838 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/SubscriptionManager.cpp')
-rw-r--r-- | cpp/src/qpid/client/SubscriptionManager.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/SubscriptionManager.cpp b/cpp/src/qpid/client/SubscriptionManager.cpp index 7445202ec3..c91ae178ac 100644 --- a/cpp/src/qpid/client/SubscriptionManager.cpp +++ b/cpp/src/qpid/client/SubscriptionManager.cpp @@ -92,6 +92,11 @@ void SubscriptionManager::start() dispatcher.start(); } +void SubscriptionManager::wait() +{ + dispatcher.wait(); +} + void SubscriptionManager::stop() { dispatcher.stop(); |