private void addBrokerRuntimePutMessageDistributeTimeMap()

in src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java [1058:1144]
87 lines of code
3 McCabe index (conditional complexity)

    private void addBrokerRuntimePutMessageDistributeTimeMap(
        String clusterName, String brokerAddress, String brokerHost,
        String brokerDes, long bootTimestamp, int brokerVersion,
        BrokerRuntimeStats stats) {
        if (stats.getPutMessageDistributeTimeMap() == null || stats.getPutMessageDistributeTimeMap().isEmpty()) {
            log.warn("WARN putMessageDistributeTime is null or empty");
            return;
        }
        brokerRuntimePutMessageDistributeTimeMap0ms.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            brokerDes,
            bootTimestamp,
            brokerVersion), stats.getPutMessageDistributeTimeMap().get("<=0ms"));
        brokerRuntimePutMessageDistributeTimeMap0to10ms.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            brokerDes,
            bootTimestamp,
            brokerVersion), stats.getPutMessageDistributeTimeMap().get("0~10ms"));
        brokerRuntimePutMessageDistributeTimeMap10to50ms.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            brokerDes,
            bootTimestamp,
            brokerVersion), stats.getPutMessageDistributeTimeMap().get("10~50ms"));
        brokerRuntimePutMessageDistributeTimeMap50to100ms.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            brokerDes,
            bootTimestamp,
            brokerVersion), stats.getPutMessageDistributeTimeMap().get("50~100ms"));
        brokerRuntimePutMessageDistributeTimeMap100to200ms.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            brokerDes,
            bootTimestamp,
            brokerVersion), stats.getPutMessageDistributeTimeMap().get("100~200ms"));
        brokerRuntimePutMessageDistributeTimeMap200to500ms.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            brokerDes,
            bootTimestamp,
            brokerVersion), stats.getPutMessageDistributeTimeMap().get("200~500ms"));
        brokerRuntimePutMessageDistributeTimeMap500to1s.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            brokerDes,
            bootTimestamp,
            brokerVersion), stats.getPutMessageDistributeTimeMap().get("500ms~1s"));
        brokerRuntimePutMessageDistributeTimeMap1to2s.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            brokerDes,
            bootTimestamp,
            brokerVersion), stats.getPutMessageDistributeTimeMap().get("1~2s"));
        brokerRuntimePutMessageDistributeTimeMap2to3s.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            brokerDes,
            bootTimestamp,
            brokerVersion), stats.getPutMessageDistributeTimeMap().get("2~3s"));
        brokerRuntimePutMessageDistributeTimeMap3to4s.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            brokerDes,
            bootTimestamp,
            brokerVersion), stats.getPutMessageDistributeTimeMap().get("3~4s"));
        brokerRuntimePutMessageDistributeTimeMap4to5s.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            brokerDes,
            bootTimestamp,
            brokerVersion), stats.getPutMessageDistributeTimeMap().get("4~5s"));
        brokerRuntimePutMessageDistributeTimeMap5to10s.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            brokerDes,
            bootTimestamp,
            brokerVersion), stats.getPutMessageDistributeTimeMap().get("5~10s"));
        brokerRuntimePutMessageDistributeTimeMap10toMore.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            brokerDes,
            bootTimestamp,
            brokerVersion), stats.getPutMessageDistributeTimeMap().get("10s~"));
    }