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-go.git
The following commit(s) were added to refs/heads/master by this push:
new 509d461 fix bug when get `mqadmin consumerStatus` can't get consume
status. (#812)
509d461 is described below
commit 509d461b8b6706ef784c4456313bb9445cd3fb34
Author: WJL3333 <[email protected]>
AuthorDate: Thu Jul 21 20:32:15 2022 +0800
fix bug when get `mqadmin consumerStatus` can't get consume status. (#812)
---
consumer/push_consumer.go | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
index 4ce8fa4..eb29a48 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -365,11 +365,11 @@ func (pc *pushConsumer) GetConsumerRunningInfo(stack
bool) *internal.ConsumerRun
topic := key.(string)
info.SubscriptionData[value.(*internal.SubscriptionData)] = true
status := internal.ConsumeStatus{
- PullRT: pc.stat.getPullRT(topic,
pc.consumerGroup).avgpt,
- PullTPS: pc.stat.getPullTPS(topic,
pc.consumerGroup).tps,
- ConsumeRT: pc.stat.getConsumeRT(topic,
pc.consumerGroup).avgpt,
- ConsumeOKTPS: pc.stat.getConsumeOKTPS(topic,
pc.consumerGroup).tps,
- ConsumeFailedTPS: pc.stat.getConsumeFailedTPS(topic,
pc.consumerGroup).tps,
+ PullRT: pc.stat.getPullRT(pc.consumerGroup,
topic).avgpt,
+ PullTPS: pc.stat.getPullTPS(pc.consumerGroup,
topic).tps,
+ ConsumeRT:
pc.stat.getConsumeRT(pc.consumerGroup, topic).avgpt,
+ ConsumeOKTPS:
pc.stat.getConsumeOKTPS(pc.consumerGroup, topic).tps,
+ ConsumeFailedTPS:
pc.stat.getConsumeFailedTPS(pc.consumerGroup, topic).tps,
ConsumeFailedMsgs:
pc.stat.topicAndGroupConsumeFailedTPS.getStatsDataInHour(topic + "@" +
pc.consumerGroup).sum,
}
info.StatusTable[topic] = status
