public void addTopicOffsetMetric()

in src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java [665:673]

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

    public void addTopicOffsetMetric(String clusterName, String brokerName, String topic, long lastUpdateTimestamp, double value) {
        if (topic.startsWith(MixAll.RETRY_GROUP_TOPIC_PREFIX)) {
            topicRetryOffset.put(new ProducerMetric(clusterName, brokerName, topic, lastUpdateTimestamp), value);
        } else if (topic.startsWith(MixAll.DLQ_GROUP_TOPIC_PREFIX)) {
            topicDLQOffset.put(new DLQTopicOffsetMetric(clusterName, brokerName, topic.replace(MixAll.DLQ_GROUP_TOPIC_PREFIX, ""), lastUpdateTimestamp), value);
        } else {
            topicOffset.put(new ProducerMetric(clusterName, brokerName, topic, lastUpdateTimestamp), value);
        }
    }