From f4a9fdb33224e5c612d59a38e34cdb48ecaba839 Mon Sep 17 00:00:00 2001 From: fanng Date: Mon, 7 Oct 2024 11:33:25 +0800 Subject: [PATCH] add pre event --- .../src/main/java/org/apache/gravitino/listener/EventBus.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/java/org/apache/gravitino/listener/EventBus.java b/core/src/main/java/org/apache/gravitino/listener/EventBus.java index d0aad072082..10b45f6a783 100644 --- a/core/src/main/java/org/apache/gravitino/listener/EventBus.java +++ b/core/src/main/java/org/apache/gravitino/listener/EventBus.java @@ -35,7 +35,7 @@ * within its internal management. */ public class EventBus { - private static final Logger LOG = LoggerFactory.getLogger(EventListenerManager.class); + private static final Logger LOG = LoggerFactory.getLogger(EventBus.class); // Holds instances of EventListenerPlugin. These instances can either be // EventListenerPluginWrapper, @@ -55,7 +55,7 @@ public EventBus(List eventListenerPlugins) { // todo: use a more general way to create preEventListeners this.preEventListeners = postEventListeners.stream() - .filter(eventListenerPlugin -> eventListenerPlugin instanceof AsyncQueueListener) + .filter(eventListenerPlugin -> !(eventListenerPlugin instanceof AsyncQueueListener)) .collect(Collectors.toList()); }