diff options
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); |
