private RPCHook getAclRPCHook()

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


    private RPCHook getAclRPCHook() {
        if (configure.enableACL()) {
            if (StringUtils.isAllBlank(configure.getAccessKey())) {
                throw new RuntimeException("acl config error: accessKey is empty");
            }
            if (StringUtils.isAllBlank(configure.getSecretKey())) {
                throw new RuntimeException("acl config error: secretKey is empty");
            }
            return new AclClientRPCHook(new SessionCredentials(configure.getAccessKey(), configure.getSecretKey()));
        }
        return null;
    }