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;
 }