summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/SessionAdapter.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2012-04-17 15:12:15 +0000
committerAlan Conway <aconway@apache.org>2012-04-17 15:12:15 +0000
commit413fba8d12f8c6b676af7f47cd5babcfc9d1020b (patch)
treed05ebd95ba9f3c5dced17706e3791bccd029704c /cpp/src/qpid/broker/SessionAdapter.cpp
parentfd83590a267c563f8cabdbf32f2dc221a7d322db (diff)
downloadqpid-python-413fba8d12f8c6b676af7f47cd5babcfc9d1020b.tar.gz
QPID-3950: Allow browsing of queues with exclusive subscriptions
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1327135 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/SessionAdapter.cpp')
-rw-r--r--cpp/src/qpid/broker/SessionAdapter.cpp1
1 files changed, 1 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/SessionAdapter.cpp b/cpp/src/qpid/broker/SessionAdapter.cpp
index 7c689d56fb..69fba58353 100644
--- a/cpp/src/qpid/broker/SessionAdapter.cpp
+++ b/cpp/src/qpid/broker/SessionAdapter.cpp
@@ -410,6 +410,7 @@ SessionAdapter::MessageHandlerImpl::subscribe(const string& queueName,
if(!destination.empty() && state.exists(destination))
throw NotAllowedException(QPID_MSG("Consumer tags must be unique"));
+ // We allow browsing (acquireMode == 1) of exclusive queues, this is required by HA.
if (queue->hasExclusiveOwner() && !queue->isExclusiveOwner(&session) && acquireMode == 0)
throw ResourceLockedException(QPID_MSG("Cannot subscribe to exclusive queue "
<< queue->getName()));