diff options
author | Carl C. Trieloff <cctrieloff@apache.org> | 2009-01-03 02:14:47 +0000 |
---|---|---|
committer | Carl C. Trieloff <cctrieloff@apache.org> | 2009-01-03 02:14:47 +0000 |
commit | 39871eccaae300ea9cd2d98eb7233781ef3daec6 (patch) | |
tree | 654092d893fc835fad2b805d3859d073d4e4e078 | |
parent | df9a8924265ccd2d2b6ad64ee71890496b0e8179 (diff) | |
download | qpid-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.cpp | 6 |
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); |