Debug code

Author: kabir

server-common/src/main/java/io/a2a/server/requesthandlers/DefaultRequestHandler.java

@@ -616,5 +616,41 @@ private void sendPushNotification(String taskId, ResultAggregator resultAggregat
         }
     }
 
+    /**
+     * Log current thread and resource statistics for debugging.
+     * Call this from debugger or add strategic calls during investigation.
+     */
+    @SuppressWarnings("unused")  // Used for debugging
+    private void logThreadStats(String label) {
+        ThreadGroup rootGroup = Thread.currentThread().getThreadGroup();
+        while (rootGroup.getParent() != null) {
+            rootGroup = rootGroup.getParent();
+        }
+        int activeThreads = rootGroup.activeCount();
+
+        LOGGER.info("=== THREAD STATS: {} ===", label);
+        LOGGER.info("Active threads: {}", activeThreads);
+        LOGGER.info("Running agents: {}", runningAgents.size());
+        LOGGER.info("Background tasks: {}", backgroundTasks.size());
+        LOGGER.info("Queue manager active queues: {}", queueManager.getClass().getSimpleName());
+
+        // List running agents
+        if (!runningAgents.isEmpty()) {
+            LOGGER.info("Running agent tasks:");
+            runningAgents.forEach((taskId, future) ->
+                LOGGER.info("  - Task {}: {}", taskId, future.isDone() ? "DONE" : "RUNNING")
+            );
+        }
+
+        // List background tasks
+        if (!backgroundTasks.isEmpty()) {
+            LOGGER.info("Background tasks:");
+            backgroundTasks.forEach(task ->
+                LOGGER.info("  - {}: {}", task, task.isDone() ? "DONE" : "RUNNING")
+            );
+        }
+        LOGGER.info("=== END THREAD STATS ===");
+    }
+
     private record MessageSendSetup(TaskManager taskManager, Task task, RequestContext requestContext) {}
 }