add pre event

apache · Oct 7, 2024 · f4a9fdb · f4a9fdb
1 parent 57f237b
commit f4a9fdb
Showing 1 changed file with 2 additions and 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
@@ -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<EventListenerPlugin> 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());
   }