clean

acl-plug/src/main/java/org/apache/rocketmq/acl/plug/AclRemotingServer.java

@@ -21,6 +21,6 @@ import org.apache.rocketmq.acl.plug.entity.AuthenticationResult;
 
 public interface AclRemotingServer {
 
-    public AuthenticationResult eachCheck(AccessControl accessControl);
+    public AuthenticationResult check(AccessControl accessControl);
 
 }

acl-plug/src/main/java/org/apache/rocketmq/acl/plug/DefaultAclRemotingServerImpl.java

@@ -30,7 +30,7 @@ public class DefaultAclRemotingServerImpl implements AclRemotingServer {
     }
 
     @Override
-    public AuthenticationResult eachCheck(AccessControl accessControl) {
+    public AuthenticationResult check(AccessControl accessControl) {
         AuthenticationResult authenticationResult = aclPlugEngine.eachCheckLoginAndAuthentication(accessControl);
         if (authenticationResult.getException() != null) {
             throw new AclPlugRuntimeException(String.format("eachCheck the inspection appear exception, accessControl data is %s", accessControl.toString()), authenticationResult.getException());

broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java

@@ -525,7 +525,7 @@ public class BrokerController {
                         accessControl.setNetaddress(StringUtils.split(remoteAddr, ":")[0]);
                         accessControl.setTopic(extFields.get("topic"));
                     }
-                    aclRemotingServe.eachCheck(accessControl);
+                    aclRemotingServe.check(accessControl);
                 }
 
                 @Override