private void loadPutMessageDistributeTime()

in src/main/java/org/apache/rocketmq/exporter/model/BrokerRuntimeStats.java [162:179]

• 18 lines of code
• 4 McCabe index (conditional complexity)

    private void loadPutMessageDistributeTime(String str) {
        if ("null".equalsIgnoreCase(str)) {
            log.warn("loadPutMessageDistributeTime WARN, value is null");
            return;
        }
        String[] arr = str.split(" ");
        String key = "", value = "";
        for (String ar : arr) {
            String[] tarr = ar.split(":");
            if (tarr.length < 2) {
                log.warn("loadPutMessageDistributeTime WARN, wrong value is {}, {}", ar, str);
                continue;
            }
            key = tarr[0].replace("[", "").replace("]", "");
            value = tarr[1];
            this.putMessageDistributeTimeMap.put(key, Integer.parseInt(value));
        }
    }