ref[event]: rename submit to post

event/src/main/java/com/zfoo/event/manager/EventBus.java

@@ -97,7 +97,7 @@ public abstract class EventBus {
     /**
      * Publish the event
      */
-    public static void submit(IEvent event) {
+    public static void post(IEvent event) {
         doSubmit(event, receiverMapSync.get(event.getClass()));
         doSubmit(event, receiverMapAsync.get(event.getClass()));
     }

event/src/test/java/com/zfoo/event/ApplicationTest.java

@@ -33,7 +33,7 @@ public class ApplicationTest {
         var context = new ClassPathXmlApplicationContext("application.xml");
 
         // see receiver method of MyController1 and MyController2
-        EventBus.submit(MyNoticeEvent.valueOf("我的事件"));
+        EventBus.post(MyNoticeEvent.valueOf("我的事件"));
 
         ThreadUtils.sleep(3000);
     }

net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java

@@ -490,7 +490,7 @@ public class ZookeeperRegistry implements IRegistry {
             } else {
                 // 连接上了服务提供者
                 session.setConsumerAttribute(providerCache);
-                EventBus.submit(ConsumerStartEvent.valueOf(providerCache, session));
+                EventBus.post(ConsumerStartEvent.valueOf(providerCache, session));
 
                 try {
                     var localRegisterVO = NetContext.getConfigManager().getLocalConfig().toLocalRegisterVO();

net/src/main/java/com/zfoo/net/handler/ClientRouteHandler.java

@@ -37,7 +37,7 @@ public class ClientRouteHandler extends BaseRouteHandler {
         super.channelActive(ctx);
         // 客户端的session初始化在启动的时候已经做了，这边直接获取session
         var session = SessionUtils.getSession(ctx);
-        EventBus.submit(ClientSessionActiveEvent.valueOf(session));
+        EventBus.post(ClientSessionActiveEvent.valueOf(session));
         logger.info("client channel is active {}", SessionUtils.sessionInfo(ctx));
     }
 
@@ -52,7 +52,7 @@ public class ClientRouteHandler extends BaseRouteHandler {
         }
 
         NetContext.getSessionManager().removeClientSession(session);
-        EventBus.submit(ClientSessionInactiveEvent.valueOf(session));
+        EventBus.post(ClientSessionInactiveEvent.valueOf(session));
 
         // 如果是消费者inactive，还需要触发客户端消费者检查事件，以便重新连接
         if (session.getConsumerAttribute() != null) {

net/src/main/java/com/zfoo/net/handler/GatewayRouteHandler.java

@@ -133,7 +133,7 @@ public class GatewayRouteHandler extends ServerRouteHandler {
         var uid = session.getUid();
 
         // 连接到网关的客户端断开了连接
-        EventBus.submit(GatewaySessionInactiveEvent.valueOf(sid, uid));
+        EventBus.post(GatewaySessionInactiveEvent.valueOf(sid, uid));
 
         super.channelInactive(ctx);
     }

net/src/main/java/com/zfoo/net/handler/ServerRouteHandler.java

@@ -38,7 +38,7 @@ public class ServerRouteHandler extends BaseRouteHandler {
         var session = initChannel(ctx.channel());
         NetContext.getSessionManager().addServerSession(session);
         logger.info("server channel is active {}", SessionUtils.sessionInfo(ctx));
-        EventBus.submit(ServerSessionActiveEvent.valueOf(session));
+        EventBus.post(ServerSessionActiveEvent.valueOf(session));
     }
 
     @Override
@@ -51,6 +51,6 @@ public class ServerRouteHandler extends BaseRouteHandler {
         }
         NetContext.getSessionManager().removeServerSession(session);
         logger.warn("server channel is inactive {}", SessionUtils.sessionSimpleInfo(ctx));
-        EventBus.submit(ServerSessionInactiveEvent.valueOf(session));
+        EventBus.post(ServerSessionInactiveEvent.valueOf(session));
     }
 }

net/src/main/java/com/zfoo/net/router/Router.java

@@ -126,7 +126,7 @@ public class Router implements IRouter {
                                     return;
                                 }
                                 session.setUid(uid);
-                                EventBus.submit(AuthUidToGatewayEvent.valueOf(gatewaySession.getSid(), uid));
+                                EventBus.post(AuthUidToGatewayEvent.valueOf(gatewaySession.getSid(), uid));
 
                                 NetContext.getRouter().send(session, AuthUidToGatewayConfirm.valueOf(uid), new GatewayAttachment(gatewaySession, null));
                                 return;
@@ -322,7 +322,7 @@ public class Router implements IRouter {
             // 这个在哪个线程处理取决于：这个上层的PacketReceiverTask被丢到了哪个线程中
             PacketBus.route(session, packet, attachment);
         } catch (Exception e) {
-            EventBus.submit(ServerExceptionEvent.valueOf(session, packet, attachment, e));
+            EventBus.post(ServerExceptionEvent.valueOf(session, packet, attachment, e));
             logger.error(StringUtils.format("e[uid:{}][sid:{}] unknown exception", session.getUid(), session.getSid(), e.getMessage()), e);
         } catch (Throwable t) {
             logger.error(StringUtils.format("e[uid:{}][sid:{}] unknown error", session.getUid(), session.getSid(), t.getMessage()), t);