private void collectProducerMetric()

in src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java [348:360]

13 lines of code
2 McCabe index (conditional complexity)


    private void collectProducerMetric(List<MetricFamilySamples> mfs) {
        GaugeMetricFamily producerCount = new GaugeMetricFamily("rocketmq_producer_count", "producer instance counter", PRODUCER_GROUP_CLIENT_METRIC_LABEL_NAMES);
        for (Map.Entry<ProducerCountMetric, Integer> entry : producerCounts.asMap().entrySet()) {
            producerCount.addMetric(
                    Arrays.asList(
                            entry.getKey().getClusterName(),
                            entry.getKey().getBrokerName(),
                            entry.getKey().getGroup()
                    ),
                    entry.getValue().doubleValue());
        }
        mfs.add(producerCount);
    }