[rocketmq-exporter] branch master updated: fix brokerRuntimePutMessageSizeTotal val

[tigerlee]

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

tigerlee 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 f395ec2  fix brokerRuntimePutMessageSizeTotal val
     new 29cdb83  Merge pull request #59 from caorong/master
f395ec2 is described below

commit f395ec28bdedca71941e0b1759f841dfab77b33a
Author: caorong <lelouc...@gmail.com>
AuthorDate: Wed Jun 16 20:47:32 2021 +0800

    fix brokerRuntimePutMessageSizeTotal val
---
 .../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 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 @@ 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(),