You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ma...@apache.org on 2022/01/05 15:27:16 UTC
[rocketmq-exporter] branch master updated: make exporter collect right putMessageSizeTotal for broker (#84)
This is an automated email from the ASF dual-hosted git repository.
maixiaohai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git
The following commit(s) were added to refs/heads/master by this push:
new 2361651 make exporter collect right putMessageSizeTotal for broker (#84)
2361651 is described below
commit 2361651afb07502379ff35c8332c2b9a6b55c66b
Author: cserwen <cs...@163.com>
AuthorDate: Wed Jan 5 23:27:11 2022 +0800
make exporter collect right putMessageSizeTotal for broker (#84)
---
.../org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java b/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java
index 4463111..ae87541 100644
--- a/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java
+++ b/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java
@@ -890,7 +890,7 @@ public class RMQMetricsCollector extends Collector {
clusterName, brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
- stats.getBrokerVersion()), stats.getQueryThreadPoolQueueCapacity());
+ stats.getBrokerVersion()), stats.getPutMessageSizeTotal());
brokerRuntimeDispatchBehindBytes.put(new BrokerRuntimeMetric(
clusterName, brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),