private void collectConsumerMetric()

in src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java [292:323]
28 lines of code
5 McCabe index (conditional complexity)

    private void collectConsumerMetric(List<MetricFamilySamples> mfs) {
        GaugeMetricFamily groupGetLatencyByConsumerDiff = new GaugeMetricFamily("rocketmq_group_diff", "GroupDiff", GROUP_DIFF_LABEL_NAMES);
        for (Map.Entry<ConsumerTopicDiffMetric, Long> entry : consumerDiff.asMap().entrySet()) {
            loadGroupDiffMetric(groupGetLatencyByConsumerDiff, entry);
        }
        mfs.add(groupGetLatencyByConsumerDiff);

        GaugeMetricFamily groupGetLatencyByConsumerRetryDiff = new GaugeMetricFamily("rocketmq_group_retrydiff", "GroupRetryDiff", GROUP_DIFF_LABEL_NAMES);
        for (Map.Entry<ConsumerTopicDiffMetric, Long> entry : consumerRetryDiff.asMap().entrySet()) {
            loadGroupDiffMetric(groupGetLatencyByConsumerRetryDiff, entry);
        }
        mfs.add(groupGetLatencyByConsumerRetryDiff);

        GaugeMetricFamily groupGetLatencyByConsumerDLQDiff = new GaugeMetricFamily("rocketmq_group_dlqdiff", "GroupDLQDiff", GROUP_DIFF_LABEL_NAMES);
        for (Map.Entry<ConsumerTopicDiffMetric, Long> entry : consumerDLQDiff.asMap().entrySet()) {
            loadGroupDiffMetric(groupGetLatencyByConsumerDLQDiff, entry);
        }
        mfs.add(groupGetLatencyByConsumerDLQDiff);

        GaugeMetricFamily consumerCountsF = new GaugeMetricFamily("rocketmq_group_count", "GroupCount", GROUP_COUNT_LABEL_NAMES);
        for (Map.Entry<ConsumerCountMetric, Integer> entry : consumerCounts.asMap().entrySet()) {
            consumerCountsF.addMetric(
                Arrays.asList(
                    entry.getKey().getCaddrs(),
                    entry.getKey().getLocaladdrs(),
                    entry.getKey().getGroup()
                ),
                entry.getValue().doubleValue());
        }
        mfs.add(consumerCountsF);

    }