diff options
Diffstat (limited to 'cpp/src/qpid/broker/SemanticState.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/SemanticState.cpp | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/SemanticState.cpp b/cpp/src/qpid/broker/SemanticState.cpp index 68c62a72ef..73ef807a0a 100644 --- a/cpp/src/qpid/broker/SemanticState.cpp +++ b/cpp/src/qpid/broker/SemanticState.cpp @@ -27,6 +27,7 @@ #include "qpid/broker/Message.h" #include "qpid/broker/Queue.h" #include "qpid/broker/SessionContext.h" +#include "qpid/broker/SessionOutputException.h" #include "qpid/broker/TxAccept.h" #include "qpid/broker/TxPublish.h" #include "qpid/framing/reply_exceptions.h" @@ -671,7 +672,11 @@ void SemanticState::reject(DeliveryId first, DeliveryId last) bool SemanticState::ConsumerImpl::doOutput() { - return haveCredit() && queue->dispatch(shared_from_this()); + try { + return haveCredit() && queue->dispatch(shared_from_this()); + } catch (const SessionException& e) { + throw SessionOutputException(e, parent->session.getChannel()); + } } void SemanticState::ConsumerImpl::enableNotify() |