public CheckResult check()

in src/main/java/com/aliyun/dts/subscribe/clients/check/SubscribeNetworkChecker.java [20:39]

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

    public CheckResult check()  {
        boolean isOk = true;
        String errMsg = null;

        try {
            retryUtil.callFunctionWithRetry(
                    () -> {
                        int index = brokerUrl.lastIndexOf(":");
                        String url = brokerUrl.substring(0, index);
                        int port = Integer.parseInt(brokerUrl.substring(index+1));
                        NetUtil.testSocket(url, port);
                    }
            );
        }  catch (Exception e) {
            isOk = false;
            errMsg = "telnet " + brokerUrl + " failed, please check the network and if the brokerUrl is correct";
        }

        return new CheckResult(isOk, errMsg);
    }