public void addWhiteList()

in src/main/java/org/apache/rocketmq/dashboard/service/impl/AclServiceImpl.java [277:295]

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

    public void addWhiteList(List<String> whiteList) {
        if (whiteList == null) {
            return;
        }
        try {
            for (String addr : getBrokerAddrs()) {
                AclConfig aclConfig = mqAdminExt.examineBrokerClusterAclConfig(addr);
                if (aclConfig.getGlobalWhiteAddrs() != null) {
                    aclConfig.setGlobalWhiteAddrs(Stream.of(whiteList, aclConfig.getGlobalWhiteAddrs()).flatMap(Collection::stream).distinct().collect(Collectors.toList()));
                } else {
                    aclConfig.setGlobalWhiteAddrs(whiteList);
                }
                mqAdminExt.updateGlobalWhiteAddrConfig(addr, StringUtils.join(aclConfig.getGlobalWhiteAddrs(), ","));
            }
        } catch (Exception e) {
            Throwables.throwIfUnchecked(e);
            throw new RuntimeException(e);
        }
    }