summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/BrokerQueue.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/BrokerQueue.cpp')
-rw-r--r--cpp/src/qpid/broker/BrokerQueue.cpp5
1 files changed, 1 insertions, 4 deletions
diff --git a/cpp/src/qpid/broker/BrokerQueue.cpp b/cpp/src/qpid/broker/BrokerQueue.cpp
index ee1a913a96..3521e63444 100644
--- a/cpp/src/qpid/broker/BrokerQueue.cpp
+++ b/cpp/src/qpid/broker/BrokerQueue.cpp
@@ -78,10 +78,7 @@ bool Queue::dispatch(Message::shared_ptr& msg){
if(consumers.empty()){
return false;
}else if(exclusive){
- if(!exclusive->deliver(msg)){
- QPID_LOG(warning, "Dropping undeliverable message from queue with exclusive consumer.");
- }
- return true;
+ return exclusive->deliver(msg);
}else{
//deliver to next consumer
next = next % consumers.size();