diff options
| author | Gordon Sim <gsim@apache.org> | 2010-01-22 10:58:20 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2010-01-22 10:58:20 +0000 |
| commit | 578ab4e8631e778bfdbb4f88b030314471394d53 (patch) | |
| tree | ee64e14b131d3dfb2a73e2045efcab7f28ef7bfa /cpp/src/qpid/broker/SemanticState.cpp | |
| parent | af58f5140110d2d8da38773a1b13f6e288f8fa56 (diff) | |
| download | qpid-python-578ab4e8631e778bfdbb4f88b030314471394d53.tar.gz | |
QPID-2347: Signal deletion of queue to active subscribers via a resource-deleted exception.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@902055 13f79535-47bb-0310-9956-ffa450edef68
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() |