From 3980af119c9651d4a910d2bfced1c52ad19758f0 Mon Sep 17 00:00:00 2001
From: godotg <jaysunxiao@gmail.com>
Date: Fri, 7 Jun 2024 18:55:51 +0800
Subject: [PATCH] perf[event]: simple exception handle and remove unnecessary
 code

---
 event/src/main/java/com/zfoo/event/manager/EventBus.java | 8 ++------
 event/src/main/java/com/zfoo/event/model/IEvent.java     | 2 +-
 2 files changed, 3 insertions(+), 7 deletions(-)

diff --git a/event/src/main/java/com/zfoo/event/manager/EventBus.java b/event/src/main/java/com/zfoo/event/manager/EventBus.java
index c7ccf2ad..0c24f826 100644
--- a/event/src/main/java/com/zfoo/event/manager/EventBus.java
+++ b/event/src/main/java/com/zfoo/event/manager/EventBus.java
@@ -33,7 +33,6 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.atomic.AtomicInteger;
-import java.util.function.BiConsumer;
 import java.util.function.Consumer;
 
 /**
@@ -57,11 +56,8 @@ public abstract class EventBus {
      */
     private static final Map<Class<? extends IEvent>, List<IEventReceiver>> receiverMap = new HashMap<>();
     /**
-     * event exception handler
+     * event noReceiver handler
      */
-    public static TriConsumer<IEventReceiver, IEvent, Throwable> exceptionFunction = (receiver, event, throwable) -> {
-        event.exceptionHandle(receiver, throwable);
-    };
     public static Consumer<IEvent> noReceiverFunction = event -> {};
 
     static {
@@ -124,7 +120,7 @@ public abstract class EventBus {
         try {
             receiver.invoke(event);
         } catch (Throwable t) {
-            exceptionFunction.accept(receiver, event, t);
+            event.exceptionHandle(receiver, t);
         }
     }
 
diff --git a/event/src/main/java/com/zfoo/event/model/IEvent.java b/event/src/main/java/com/zfoo/event/model/IEvent.java
index 427cf452..c643488e 100644
--- a/event/src/main/java/com/zfoo/event/model/IEvent.java
+++ b/event/src/main/java/com/zfoo/event/model/IEvent.java
@@ -49,6 +49,6 @@ public interface IEvent {
      * @param throwable Throwable
      */
     default void exceptionHandle(IEventReceiver receiver, Throwable throwable) {
-        logger.error("eventBus {} [{}] unknown error", receiver.bus(), this.getClass().getSimpleName(), throwable);
+        logger.error("bean:[{}] event:[{}] unhandled exception", receiver.getBean().getClass().getSimpleName(), this.getClass().getSimpleName(), throwable);
     }
 }