From 6d37f07bdb6bccf4a7e0b729517710a4d70d0a0b Mon Sep 17 00:00:00 2001 From: Stephan Richter Date: Mon, 10 Aug 2026 21:40:02 +0200 Subject: [PATCH] logging/tuning reconnect of event source Signed-off-by: Stephan Richter --- .../java/de/srsoftware/umbrella/messagebus/MessageApi.java | 3 +++ frontend/src/urls.svelte.js | 3 +++ 2 files changed, 6 insertions(+) diff --git a/bus/src/main/java/de/srsoftware/umbrella/messagebus/MessageApi.java b/bus/src/main/java/de/srsoftware/umbrella/messagebus/MessageApi.java index 09c8136a..347c4ee1 100644 --- a/bus/src/main/java/de/srsoftware/umbrella/messagebus/MessageApi.java +++ b/bus/src/main/java/de/srsoftware/umbrella/messagebus/MessageApi.java @@ -42,6 +42,9 @@ public class MessageApi extends BaseHandler{ ex.sendResponseHeaders(HTTP_OK,0); try (var os = ex.getResponseBody(); var stream = new PrintWriter(os); var eventQueue = new EventQueue(addr)){ LOG.log(INFO,"{0} opened event stream.",addr); + stream.print("retry: 3000\n\n"); + stream.flush(); + var counter = 0; while (!stream.checkError()){ sleep(100); diff --git a/frontend/src/urls.svelte.js b/frontend/src/urls.svelte.js index 046648ce..d6477e1d 100644 --- a/frontend/src/urls.svelte.js +++ b/frontend/src/urls.svelte.js @@ -22,6 +22,9 @@ export function eventStream(createHandler,updateHandler,deleteHandler){ if (createHandler) es.addEventListener('CREATE', createHandler); if (updateHandler) es.addEventListener('UPDATE', updateHandler); if (deleteHandler) es.addEventListener('DELETE', deleteHandler); + es.onerror = (err) => { + console.log("SSE error (reconnecting automatically):", err); + }; return es; }