public static boolean isBrokerExist()

in java/e2e-v4/src/main/java/org/apache/rocketmq/utils/MQAdmin.java [121:138]

• 17 lines of code
• 5 McCabe index (conditional complexity)

    public static boolean isBrokerExist(String ns, String ip) {
        ClusterInfo clusterInfo = getCluster(ns);
        if (clusterInfo == null) {
            return false;
        } else {
            HashMap<String, BrokerData> brokers = clusterInfo.getBrokerAddrTable();
            for (Entry<String, BrokerData> brokerEntry : brokers.entrySet()) {
                HashMap<Long, String> brokerIps = brokerEntry.getValue().getBrokerAddrs();
                for (Entry<Long, String> brokerIdEntry : brokerIps.entrySet()) {
                    if (brokerIdEntry.getValue().contains(ip)) {
                        return true;
                    }
                }
            }
        }

        return false;
    }