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;
}