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 | bbb389c5f081388ba96ae2378e6b91bf6fa27432 (patch) | |
| tree | 97b63d56057c084016d20f6c00b140d2f3ae529d /cpp/src/qpid | |
| parent | b257c3e248e2a7a66109d66a6bb1e120fd8f05a0 (diff) | |
| download | qpid-python-bbb389c5f081388ba96ae2378e6b91bf6fa27432.tar.gz | |
stats correction pointed out by gordon
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@730890 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid')
| -rw-r--r-- | cpp/src/qpid/broker/Queue.cpp | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp index de30c45acd..9089ba0c54 100644 --- a/cpp/src/qpid/broker/Queue.cpp +++ b/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); |