Broker 优化鉴权与注册顺序

noear · Dec 5, 2023 · d02bf64 · d02bf64
1 parent 480abba
commit d02bf64
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/folkmq-broker/src/main/java/org/noear/folkmq/broker/mq/BrokerListenerFolkmq.java b/folkmq-broker/src/main/java/org/noear/folkmq/broker/mq/BrokerListenerFolkmq.java
@@ -45,8 +45,6 @@ public BrokerListenerFolkmq addAccessAll(Map<String, String> accessMap) {
 
     @Override
     public void onOpen(Session session) throws IOException {
-        super.onOpen(session);
-
         if (serverAccessMap.size() > 0) {
             //如果有 ak/sk 配置，则进行鉴权
             String accessKey = session.param(MqConstants.PARAM_ACCESS_KEY);
@@ -63,6 +61,8 @@ public void onOpen(Session session) throws IOException {
             }
         }
 
+        super.onOpen(session);
+
         log.info("Server channel opened, sessionId={}", session.sessionId());
     }