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, List> receiverMap = new HashMap<>(); /** - * event exception handler + * event noReceiver handler */ - public static TriConsumer exceptionFunction = (receiver, event, throwable) -> { - event.exceptionHandle(receiver, throwable); - }; public static Consumer 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); } }