summaryrefslogtreecommitdiff
path: root/cpp/src/qpid
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid')
-rw-r--r--cpp/src/qpid/broker/Queue.cpp6
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);