diff options
Diffstat (limited to 'cpp/src/qpid/client/Dispatcher.cpp')
-rw-r--r-- | cpp/src/qpid/client/Dispatcher.cpp | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/cpp/src/qpid/client/Dispatcher.cpp b/cpp/src/qpid/client/Dispatcher.cpp index 37b37d9077..2bbe5a122f 100644 --- a/cpp/src/qpid/client/Dispatcher.cpp +++ b/cpp/src/qpid/client/Dispatcher.cpp @@ -88,10 +88,12 @@ void Dispatcher::run() } } } - } catch (const ClosedException&) { - //ignore it and return + session.sync(); // Make sure all our acks are received before returning. + } + catch (const ClosedException&) {} //ignore it and return + catch (const std::exception& e) { + QPID_LOG(error, "Exception in client dispatch thread: " << e.what()); } - session.sync(); // Make sure all our acks are received before returning. } void Dispatcher::stop() |