(rocketmq-client-cpp) branch master updated: fix: metrics pull rt was reported as consume rt (#478)

[dinglei]

This is an automated email from the ASF dual-hosted git repository.

dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-cpp.git


The following commit(s) were added to refs/heads/master by this push:
     new 47eba05  fix: metrics pull rt was reported as consume rt (#478)
47eba05 is described below

commit 47eba056a058b4abf6ae34a287316cd83f2df38a
Author: Humkum <1109939...@qq.com>
AuthorDate: Thu Feb 27 19:48:05 2025 +0800

    fix: metrics pull rt was reported as consume rt (#478)
---
 src/consumer/DefaultMQPushConsumerImpl.cpp | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/consumer/DefaultMQPushConsumerImpl.cpp 
b/src/consumer/DefaultMQPushConsumerImpl.cpp
index ea087d9..c7ee30e 100644
--- a/src/consumer/DefaultMQPushConsumerImpl.cpp
+++ b/src/consumer/DefaultMQPushConsumerImpl.cpp
@@ -67,7 +67,7 @@ class AsyncPullCallback : public PullCallback {
         }
 
         uint64 pullRT = UtilAll::currentTimeMillis() - 
pullRequest->getLastPullTimestamp();
-        
StatsServerManager::getInstance()->getConsumeStatServer()->incConsumeRT(
+        StatsServerManager::getInstance()->getConsumeStatServer()->incPullRT(
             pullRequest->m_messageQueue.getTopic(), 
m_callbackOwner->getGroupName(), pullRT);
         pullRequest->setNextOffset(result.nextBeginOffset);
         pullRequest->putMessage(result.msgFoundList);
@@ -707,7 +707,7 @@ void 
DefaultMQPushConsumerImpl::pullMessage(boost::weak_ptr<PullRequest> pullReq
     switch (pullResult.pullStatus) {
       case FOUND: {
         uint64 pullRT = UtilAll::currentTimeMillis() - startTimeStamp;
-        
StatsServerManager::getInstance()->getConsumeStatServer()->incConsumeRT(messageQueue.getTopic(),
 getGroupName(),
+        
StatsServerManager::getInstance()->getConsumeStatServer()->incPullRT(messageQueue.getTopic(),
 getGroupName(),
                                                                                
 pullRT);
         if (request->isDropped()) {
           LOG_INFO("Get pull result but the queue has been marked as dropped. 
Queue: %s",