1 files changed, 7 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp
index ef1358feb9..116e8d9431 100644
--- a/cpp/src/qpid/broker/Queue.cpp
+++ b/cpp/src/qpid/broker/Queue.cpp
@@ -293,6 +293,10 @@ void Queue::consume(Consumer::ptr c, bool requestExclusive){
         }
         browsers.push_back(c);
     }
+
+    if (mgmtObjectPtr != 0){
+        mgmtObjectPtr->incConsumers ();
+    }
 }
 
 void Queue::cancel(Consumer::ptr c){
@@ -302,6 +306,9 @@ void Queue::cancel(Consumer::ptr c){
     } else {
         cancel(c, browsers);
     }
+    if (mgmtObjectPtr != 0){
+        mgmtObjectPtr->decConsumers ();
+    }
     if(exclusive == c) exclusive.reset();
 }