Unregister uninstalled event listeners

Signed-off-by: Alexander Pinčuk <alexander.v.pinchuk@gmail.com>
eclipse-ee4j · Feb 22, 2024 · 5476894 · 5476894
1 parent 352fc91
commit 5476894
Showing 1 changed file with 14 additions and 9 deletions.
diff --git a/nucleus/core/kernel/src/main/java/org/glassfish/kernel/event/EventsImpl.java b/nucleus/core/kernel/src/main/java/org/glassfish/kernel/event/EventsImpl.java
@@ -20,6 +20,7 @@
 import jakarta.inject.Inject;
 
 import java.lang.reflect.Method;
+import java.util.Iterator;
 import java.util.Queue;
 import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.ExecutorService;
@@ -62,8 +63,11 @@ public void send(final Event<?> event) {
 
     @Override
     public void send(final Event<?> event, boolean asynchronously) {
-        for (final EventListener listener : listeners) {
-            Method eventMethod = null;
+        Iterator<EventListener> iterator = listeners.iterator();
+        while (iterator.hasNext()) {
+            EventListener listener = iterator.next();
+
+            Method eventMethod;
             try {
                 // Check if the listener is interested with his event.
                 eventMethod = listener.getClass().getMethod("event", Event.class);
@@ -78,14 +82,15 @@ public void send(final Event<?> event, boolean asynchronously) {
                 // As a result, an exception like NoClassDefFoundError is thrown
                 // from getMethod.
                 logger.log(Level.SEVERE, KernelLoggerInfo.exceptionSendEvent, t);
+                iterator.remove();
+                continue;
             }
-            if (eventMethod != null) {
-                RestrictTo restrictTo = eventMethod.getParameters()[0].getAnnotation(RestrictTo.class);
-                if (restrictTo != null) {
-                    EventTypes<?> interested = EventTypes.create(restrictTo.value());
-                    if (!event.is(interested)) {
-                        continue;
-                    }
+
+            RestrictTo restrictTo = eventMethod.getParameters()[0].getAnnotation(RestrictTo.class);
+            if (restrictTo != null) {
+                EventTypes<?> interested = EventTypes.create(restrictTo.value());
+                if (!event.is(interested)) {
+                    continue;
                 }
             }