Author: tross
Date: Tue Dec  2 04:56:48 2008
New Revision: 722446

URL: http://svn.apache.org/viewvc?rev=722446&view=rev
Log:
Added management accounting for transaction dequeues.

Modified:
    incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp

Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp?rev=722446&r1=722445&r2=722446&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp Tue Dec  2 04:56:48 
2008
@@ -626,6 +626,10 @@
 {
     Mutex::ScopedLock locker(messageLock);
     dequeued(msg);    
+    if (mgmtObject != 0) {
+        mgmtObject->inc_msgTxnDequeues();
+        mgmtObject->inc_byteTxnDequeues(msg.payload->contentSize());
+    }
 }
 
 /**


Reply via email to