private void collectTopicNums()

in src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java [638:650]

• 12 lines of code
• 3 McCabe index (conditional complexity)

    private void collectTopicNums(List<MetricFamilySamples> mfs) {
        GaugeMetricFamily topicPutNumsGauge = new GaugeMetricFamily("rocketmq_producer_tps", "TopicPutNums", TOPIC_NUMS_LABEL_NAMES);
        for (Map.Entry<TopicPutNumMetric, Double> entry : topicPutNums.asMap().entrySet()) {
            loadTopicNumsMetric(topicPutNumsGauge, entry);
        }
        mfs.add(topicPutNumsGauge);

        GaugeMetricFamily topicPutSizeGauge = new GaugeMetricFamily("rocketmq_producer_message_size", "TopicPutMessageSize", TOPIC_NUMS_LABEL_NAMES);
        for (Map.Entry<TopicPutNumMetric, Double> entry : topicPutSize.asMap().entrySet()) {
            loadTopicNumsMetric(topicPutSizeGauge, entry);
        }
        mfs.add(topicPutSizeGauge);
    }