summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/Dispatcher.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/client/Dispatcher.cpp')
-rw-r--r--cpp/src/qpid/client/Dispatcher.cpp8
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()