summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/SessionImpl.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2008-06-12 19:19:22 +0000
committerAlan Conway <aconway@apache.org>2008-06-12 19:19:22 +0000
commitc3c98db893d6e127dc5e0037fb2c3548e8f90a5a (patch)
treee3d43bfd62f9423c951df3bb3ea8dc2ba4aa2de3 /cpp/src/qpid/client/SessionImpl.cpp
parentcaecb76180dfe85da79064e9733a3ca79c55f141 (diff)
downloadqpid-python-c3c98db893d6e127dc5e0037fb2c3548e8f90a5a.tar.gz
Propagate error messages across the Demux between network & user threads.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@667205 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/SessionImpl.cpp')
-rw-r--r--cpp/src/qpid/client/SessionImpl.cpp4
1 files changed, 3 insertions, 1 deletions
diff --git a/cpp/src/qpid/client/SessionImpl.cpp b/cpp/src/qpid/client/SessionImpl.cpp
index 7b8cae943f..574c71ecd7 100644
--- a/cpp/src/qpid/client/SessionImpl.cpp
+++ b/cpp/src/qpid/client/SessionImpl.cpp
@@ -616,7 +616,9 @@ void SessionImpl::assertOpen() const
void SessionImpl::handleClosed()
{
- demux.close();
+ // FIXME aconway 2008-06-12: needs to be set to the correct exception type.
+ //
+ demux.close(sys::ExceptionHolder(text.empty() ? new ClosedException() : new Exception(text)));
results.close();
}