summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2009-01-03 02:14:47 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2009-01-03 02:14:47 +0000
commit39871eccaae300ea9cd2d98eb7233781ef3daec6 (patch)
tree654092d893fc835fad2b805d3859d073d4e4e078
parentdf9a8924265ccd2d2b6ad64ee71890496b0e8179 (diff)
downloadqpid-python-39871eccaae300ea9cd2d98eb7233781ef3daec6.tar.gz
stats correction pointed out by gordon
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@730890 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/cpp/src/qpid/broker/Queue.cpp6
1 files changed, 2 insertions, 4 deletions
diff --git a/qpid/cpp/src/qpid/broker/Queue.cpp b/qpid/cpp/src/qpid/broker/Queue.cpp
index de30c45acd..9089ba0c54 100644
--- a/qpid/cpp/src/qpid/broker/Queue.cpp
+++ b/qpid/cpp/src/qpid/broker/Queue.cpp
@@ -515,10 +515,8 @@ void Queue::push(boost::intrusive_ptr<Message>& msg){
lvq[key] = msg;
}else {
i->second->setReplacementMessage(msg,this);
- if (mgmtObject != 0) {
- mgmtObject->inc_msgTotalDequeues();
- mgmtObject->inc_byteTotalDequeues(msg->contentSize());
- }
+ qm.payload = i->second;
+ dequeued(qm);
}
}else {
messages.push_back(qm);