commit 29cdb83b093372fa43772fbac3d6dd8d7f9c397c
author francis lee <francislee.cn@outlook.com> Fri Jul 23 00:25:29 2021 +0800
committer GitHub <noreply@github.com> Fri Jul 23 00:25:29 2021 +0800
tree 9ef5c5cee96b8a60214077baaca01674a2a54aba
parent 0cf384687045020fd0d52e9f4c081aa1778381e4
parent f395ec28bdedca71941e0b1759f841dfab77b33a

Merge pull request #59 from caorong/master

fix brokerRuntimePutMessageSizeTotal val

src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java

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 d3a79c2..dcb3577 100644
--- a/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java
+++ b/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java
@@ -812,7 +812,7 @@
                 clusterName, brokerAddress, brokerHost,
                 stats.getBrokerVersionDesc(),
                 stats.getBootTimestamp(),
-                stats.getBrokerVersion()), stats.getQueryThreadPoolQueueCapacity());
+                stats.getBrokerVersion()), stats.getPutMessageSizeTotal());
         brokerRuntimeDispatchBehindBytes.put(new BrokerRuntimeMetric(
                 clusterName, brokerAddress, brokerHost,
                 stats.getBrokerVersionDesc(),