diff --git a/hub/src/sse/sseManager.ts b/hub/src/sse/sseManager.ts
index 2bd267b9..8461c558 100644
--- a/hub/src/sse/sseManager.ts
+++ b/hub/src/sse/sseManager.ts
@@ -156,7 +156,7 @@ export class SSEManager {
         }
 
         if (event.type === 'message-received') {
-            return connection.sessionId === event.sessionId
+            return connection.all || connection.sessionId === event.sessionId
         }
 
         if (event.type === 'connection-changed') {