summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/Dispatcher.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-11-06 10:47:57 +0000
committerGordon Sim <gsim@apache.org>2008-11-06 10:47:57 +0000
commit92914dcf983f5328a19648950ab8d2c42ca77925 (patch)
tree179a813bc70cfdf6ffb7affd4d5cdee5c472a2f9 /cpp/src/qpid/client/Dispatcher.cpp
parent3cb32fb199ccf271da1c08f355940c2550d48464 (diff)
downloadqpid-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/Dispatcher.cpp')
-rw-r--r--cpp/src/qpid/client/Dispatcher.cpp5
1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/Dispatcher.cpp b/cpp/src/qpid/client/Dispatcher.cpp
index da6607fb9e..59bc265bd2 100644
--- a/cpp/src/qpid/client/Dispatcher.cpp
+++ b/cpp/src/qpid/client/Dispatcher.cpp
@@ -54,6 +54,11 @@ void Dispatcher::start()
worker = Thread(this);
}
+void Dispatcher::wait()
+{
+ worker.join();
+}
+
void Dispatcher::run()
{
Mutex::ScopedLock l(lock);