From b29a37f7a14c41592bd0b758d2b163492d3c99d2 Mon Sep 17 00:00:00 2001
From: Ted Ross <tross@apache.org>
Date: Tue, 2 Dec 2008 12:56:48 +0000
Subject: Added management accounting for transaction dequeues.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722446 13f79535-47bb-0310-9956-ffa450edef68
---
 cpp/src/qpid/broker/Queue.cpp | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'cpp/src/qpid/broker/Queue.cpp')

diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp
index 163c471286..22659ec26c 100644
--- a/cpp/src/qpid/broker/Queue.cpp
+++ b/cpp/src/qpid/broker/Queue.cpp
@@ -626,6 +626,10 @@ void Queue::dequeueCommitted(const QueuedMessage& msg)
 {
     Mutex::ScopedLock locker(messageLock);
     dequeued(msg);    
+    if (mgmtObject != 0) {
+        mgmtObject->inc_msgTxnDequeues();
+        mgmtObject->inc_byteTxnDequeues(msg.payload->contentSize());
+    }
 }
 
 /**
-- 
cgit v1.2.1