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.h | |
| 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.h')
| -rw-r--r-- | cpp/src/qpid/client/SubscriptionManager.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/SubscriptionManager.h b/cpp/src/qpid/client/SubscriptionManager.h index 58d880fa83..948126e271 100644 --- a/cpp/src/qpid/client/SubscriptionManager.h +++ b/cpp/src/qpid/client/SubscriptionManager.h @@ -210,6 +210,11 @@ class SubscriptionManager : public sys::Runnable * @see start */ void start(); + + /** + * Wait for the thread started by a call to start() to complete. + */ + void wait(); /** If set true, run() will stop when all subscriptions * are cancelled. If false, run will only stop when stop() |