private DefaultMQAdminExt buildDefaultMQAdminExt()

in src/main/java/org/apache/rocketmq/exporter/service/client/MQAdminInstance.java [68:83]

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

    private DefaultMQAdminExt buildDefaultMQAdminExt() throws Exception {
        String namesrvAddress = configure.getNamesrvAddr();
        if (StringUtils.isBlank(namesrvAddress)) {
            log.error("Build DefaultMQAdminExt error, namesrv is null");
            throw new Exception("Build DefaultMQAdminExt error, namesrv is null", null);
        }
        DefaultMQAdminExt defaultMQAdminExt = new DefaultMQAdminExt(this.aclHook,5000L);
        defaultMQAdminExt.setInstanceName("admin-" + System.currentTimeMillis());
        defaultMQAdminExt.setNamesrvAddr(namesrvAddress);
        try {
            defaultMQAdminExt.start();
        } catch (MQClientException ex) {
            log.error(String.format("init default admin error, namesrv=%s", System.getProperty(MixAll.NAMESRV_ADDR_PROPERTY)), ex);
        }
        return defaultMQAdminExt;
    }