Clean up queue closing

Author: kabir

core/src/main/java/io/a2a/server/events/EventQueue.java

@@ -87,7 +87,9 @@ public void taskDone() {
         // TODO Not sure if needed yet. BlockingQueue.poll()/.take() remove the events.
     }
 
-    public void close() {
+    public abstract void close();
+
+    public void doClose() {
         synchronized (this) {
             if (closed) {
                 return;
@@ -138,8 +140,8 @@ void signalQueuePollerStarted() {
 
         @Override
         public void close() {
-            super.close();
-            children.forEach(EventQueue::close);
+            doClose();
+            children.forEach(EventQueue::doClose);
         }
     }
 
@@ -173,5 +175,10 @@ public void awaitQueuePollerStart() throws InterruptedException {
         void signalQueuePollerStarted() {
             parent.signalQueuePollerStarted();
         }
+
+        @Override
+        public void close() {
+            parent.close();
+        }
     }
 }