summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/Demux.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2007-12-01 05:11:38 +0000
committerAlan Conway <aconway@apache.org>2007-12-01 05:11:38 +0000
commit9a5521b5aaaf1f620c4210ecf09e180ed2934988 (patch)
tree9f71cab2186c5c3ccf4730efb1a3bf819f535a9b /cpp/src/qpid/client/Demux.cpp
parent1ef2d3ad182ca4ec136632c35f7ac173a1601eb5 (diff)
downloadqpid-python-9a5521b5aaaf1f620c4210ecf09e180ed2934988.tar.gz
Fix problem where client does notice disconnection from Broker.
src/qpid/client/SessionCore.cpp: close/open Demux on suspend/resume. src/tests/exception_test.cpp: convert to Session API, boost test. - Temporarily disabled due issues noted in TODO comments git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@600046 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/Demux.cpp')
-rw-r--r--cpp/src/qpid/client/Demux.cpp9
1 files changed, 9 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/Demux.cpp b/cpp/src/qpid/client/Demux.cpp
index bd1dda0ae9..e61103981b 100644
--- a/cpp/src/qpid/client/Demux.cpp
+++ b/cpp/src/qpid/client/Demux.cpp
@@ -74,6 +74,15 @@ void Demux::close()
defaultQueue->close();
}
+void Demux::open()
+{
+ sys::Mutex::ScopedLock l(lock);
+ for (iterator i = records.begin(); i != records.end(); i++) {
+ i->queue->open();
+ }
+ defaultQueue->open();
+}
+
Demux::QueuePtr Demux::add(const std::string& name, Condition condition)
{
sys::Mutex::ScopedLock l(lock);