From f2dcde94954a39454b219baaed6b7f963772bc4f Mon Sep 17 00:00:00 2001
From: hujie <hujie@aijiatui.com>
Date: Wed, 10 Oct 2018 22:47:29 +0800
Subject: [PATCH] clean

---
 .../java/org/apache/rocketmq/acl/plug/AclRemotingServer.java    | 2 +-
 .../apache/rocketmq/acl/plug/DefaultAclRemotingServerImpl.java  | 2 +-
 .../main/java/org/apache/rocketmq/broker/BrokerController.java  | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/acl-plug/src/main/java/org/apache/rocketmq/acl/plug/AclRemotingServer.java b/acl-plug/src/main/java/org/apache/rocketmq/acl/plug/AclRemotingServer.java
index 30df3814..ded9f80c 100644
--- a/acl-plug/src/main/java/org/apache/rocketmq/acl/plug/AclRemotingServer.java
+++ b/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);
 
 }
diff --git a/acl-plug/src/main/java/org/apache/rocketmq/acl/plug/DefaultAclRemotingServerImpl.java b/acl-plug/src/main/java/org/apache/rocketmq/acl/plug/DefaultAclRemotingServerImpl.java
index 0e8be9f7..4ea14b48 100644
--- a/acl-plug/src/main/java/org/apache/rocketmq/acl/plug/DefaultAclRemotingServerImpl.java
+++ b/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());
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
index 5c8fe236..e7e8097f 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/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
-- 
GitLab