[rocketmq-mqtt] branch develop updated: fix prometheus log error when set prometheus to false

[pingww]

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

pingww pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git


The following commit(s) were added to refs/heads/develop by this push:
     new fa2d920  fix prometheus log error when set prometheus to false
     new c50ae5b  Merge pull request #183 from DongyuanPan/fix_prometheus
fa2d920 is described below

commit fa2d9204559ad0e738238c2c7554a56776945a6c
Author: dongyuan.pdy <dongyuanp...@gmail.com>
AuthorDate: Mon Feb 20 14:55:37 2023 +0800

    fix prometheus log error when set prometheus to false
---
 .../apache/rocketmq/mqtt/exporter/collector/MqttMetricsCollector.java | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector/MqttMetricsCollector.java
 
b/mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector/MqttMetricsCollector.java
index 60a0a1e..201bb06 100644
--- 
a/mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector/MqttMetricsCollector.java
+++ 
b/mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector/MqttMetricsCollector.java
@@ -111,6 +111,10 @@ public class MqttMetricsCollector {
     }
 
     private static void collect(MqttMetricsInfo mqttMetricsInfo, long val, 
String... labels) throws PrometheusException {
+        if (!initialized) {
+            return;
+        }
+
         Map<MqttMetricsInfo, Collector> mqttMetricsInfoCollectorTypeMap = 
ALL_TYPE_COLLECTORS.get(mqttMetricsInfo.getType());
         if (mqttMetricsInfoCollectorTypeMap == null) {
             throw new PrometheusException("mqttMetricsInfo unregistered or 
collector type not support: " + mqttMetricsInfo);