public void updateAclConfig()

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


    public void updateAclConfig(PlainAccessConfig config) {
        try {
            for (String addr : getBrokerAddrs()) {
                AclConfig aclConfig = mqAdminExt.examineBrokerClusterAclConfig(addr);
                if (aclConfig.getPlainAccessConfigs() != null) {
                    PlainAccessConfig remoteConfig = null;
                    for (PlainAccessConfig pac : aclConfig.getPlainAccessConfigs()) {
                        if (pac.getAccessKey().equals(config.getAccessKey())) {
                            remoteConfig = pac;
                            break;
                        }
                    }
                    if (remoteConfig != null) {
                        remoteConfig.setSecretKey(config.getSecretKey());
                        remoteConfig.setAdmin(config.isAdmin());
                        config = remoteConfig;
                    }
                }
                mqAdminExt.createAndUpdatePlainAccessConfig(addr, config);
            }
        } catch (Exception e) {
            Throwables.throwIfUnchecked(e);
            throw new RuntimeException(e);
        }
    }