* sse: add listener context

Signed-off-by: neo <1100909+neowu@users.noreply.github.com>

Author: neowu

CHANGELOG.md

@@ -11,6 +11,7 @@
   > support JSONB type, use "?::jsonb" instead of "?" for jsonb query
   > support gcloud IAM auth
 * log-exporter: strict schema definition
+* sse: add listener context
 
 ### 9.2.1 (4/24/2025 - 5/19/2025) !!! only support java 24
 

core-ng/src/main/java/core/framework/internal/web/sse/ServerSentEventCloseHandler.java

@@ -34,6 +34,7 @@ public void exchangeEvent(HttpServerExchange exchange, NextListener next) {
                 actionLog.context("client_ip", channel.clientIP);
                 if (channel.traceId != null) actionLog.context("trace_id", channel.traceId);
 
+                actionLog.context("listener", support.listener.getClass().getCanonicalName());
                 support.listener.onClose(channel);
 
                 if (!channel.groups.isEmpty()) actionLog.context("group", channel.groups.toArray());

core-ng/src/main/java/core/framework/internal/web/sse/ServerSentEventHandler.java

@@ -118,7 +118,10 @@ void handle(HttpServerExchange exchange, StreamSinkChannel sink) {
             request.session = ReadOnlySession.of(sessionManager.load(request, actionLog));
             String lastEventId = exchange.getRequestHeaders().getLast(LAST_EVENT_ID);
             if (lastEventId != null) actionLog.context("last_event_id", lastEventId);
+
+            actionLog.context("listener", support.listener.getClass().getCanonicalName());
             support.listener.onConnect(request, channel, lastEventId);
+
             if (!channel.groups.isEmpty()) actionLog.context("group", channel.groups.toArray()); // may join group onConnect
         } catch (Throwable e) {
             logManager.logError(e);