Eagerly initialise the processor to get the reference tests passing

Author: kabir

reference/jsonrpc/src/test/resources/application.properties

@@ -1 +1,6 @@
 quarkus.arc.selected-alternatives=io.a2a.server.apps.common.TestHttpClient
+
+# Debug logging for event processing and request handling
+quarkus.log.category."io.a2a.server.events".level=DEBUG
+quarkus.log.category."io.a2a.server.requesthandlers".level=DEBUG
+quarkus.log.category."io.a2a.server.tasks".level=DEBUG

server-common/src/main/java/io/a2a/server/events/MainEventBusProcessor.java

@@ -30,6 +30,10 @@
  * This architecture ensures clients never receive events before they're persisted,
  * eliminating race conditions and enabling reliable event replay.
  * </p>
+ * <p>
+ * <b>Note:</b> This bean is eagerly initialized by {@link MainEventBusProcessorInitializer}
+ * to ensure the background thread starts automatically when the application starts.
+ * </p>
  */
 @ApplicationScoped
 public class MainEventBusProcessor implements Runnable {
@@ -79,6 +83,14 @@ void start() {
         LOGGER.info("MainEventBusProcessor started");
     }
 
+    /**
+     * No-op method to force CDI proxy resolution and ensure @PostConstruct has been called.
+     * Called by MainEventBusProcessorInitializer during application startup.
+     */
+    public void ensureStarted() {
+        // Method intentionally empty - just forces proxy resolution
+    }
+
     @PreDestroy
     void stop() {
         LOGGER.info("MainEventBusProcessor stopping...");

server-common/src/main/java/io/a2a/server/events/MainEventBusProcessorInitializer.java

@@ -0,0 +1,43 @@
+package io.a2a.server.events;
+
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.enterprise.context.Initialized;
+import jakarta.enterprise.event.Observes;
+import jakarta.inject.Inject;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Portable CDI initializer for MainEventBusProcessor.
+ * <p>
+ * This bean observes the ApplicationScoped initialization event and injects
+ * MainEventBusProcessor, which triggers its eager creation and starts the background thread.
+ * </p>
+ * <p>
+ * This approach is portable across all Jakarta CDI implementations (Weld, OpenWebBeans, Quarkus, etc.)
+ * and ensures MainEventBusProcessor starts automatically when the application starts.
+ * </p>
+ */
+@ApplicationScoped
+public class MainEventBusProcessorInitializer {
+    private static final Logger LOGGER = LoggerFactory.getLogger(MainEventBusProcessorInitializer.class);
+
+    @Inject
+    MainEventBusProcessor processor;
+
+    /**
+     * Observes ApplicationScoped initialization to force eager creation of MainEventBusProcessor.
+     * The injection of MainEventBusProcessor in this bean triggers its creation, and calling
+     * ensureStarted() forces the CDI proxy to be resolved, which ensures @PostConstruct has been
+     * called and the background thread is running.
+     */
+    void onStart(@Observes @Initialized(ApplicationScoped.class) Object event) {
+        if (processor != null) {
+            // Force proxy resolution to ensure @PostConstruct has been called
+            processor.ensureStarted();
+            LOGGER.info("MainEventBusProcessor initialized and started");
+        } else {
+            LOGGER.error("MainEventBusProcessor is null - initialization failed!");
+        }
+    }
+}