diff --git a/src/main/java/org/apache/rocketmq/dashboard/aspect/admin/MQAdminAspect.java b/src/main/java/org/apache/rocketmq/dashboard/aspect/admin/MQAdminAspect.java index fd63555..4b5bd21 100644 --- a/src/main/java/org/apache/rocketmq/dashboard/aspect/admin/MQAdminAspect.java +++ b/src/main/java/org/apache/rocketmq/dashboard/aspect/admin/MQAdminAspect.java @@ -80,7 +80,7 @@ public class MQAdminAspect { String methodName = joinPoint.getSignature().getName(); try { - if (isPoolConfigIsolatedByUser(rmqConfigure.isLoginRequired(), methodName)) { + if (isPoolConfigIsolatedByUser(rmqConfigure.isLoginRequired(), rmqConfigure.getAuthMode(), methodName)) { currentUserInfo = (UserInfo) UserInfoContext.get(WebUtil.USER_NAME); // 2. Borrow the user-specific MQAdminExt instance. // currentUser.getName() is assumed to be the AccessKey, and currentUser.getPassword() is SecretKey. @@ -123,8 +123,8 @@ public class MQAdminAspect { } } - private boolean isPoolConfigIsolatedByUser(boolean loginRequired, String methodName) { - if (!loginRequired) { + private boolean isPoolConfigIsolatedByUser(boolean loginRequired, String authMode, String methodName) { + if (!loginRequired || authMode.equals("file")) { return false; } else { return !METHODS_TO_CHECK.contains(methodName);