diff --git a/packages/server/src/queue/RedisEventSubscriber.ts b/packages/server/src/queue/RedisEventSubscriber.ts
index 81b18e3c..af78d280 100644
--- a/packages/server/src/queue/RedisEventSubscriber.ts
+++ b/packages/server/src/queue/RedisEventSubscriber.ts
@@ -85,6 +85,15 @@ export class RedisEventSubscriber {
             case 'nextAgent':
                 this.sseStreamer.streamNextAgentEvent(chatId, data)
                 break
+            case 'agentFlowEvent':
+                this.sseStreamer.streamAgentFlowEvent(chatId, data)
+                break
+            case 'agentFlowExecutedData':
+                this.sseStreamer.streamAgentFlowExecutedDataEvent(chatId, data)
+                break
+            case 'nextAgentFlow':
+                this.sseStreamer.streamNextAgentFlowEvent(chatId, data)
+                break
             case 'action':
                 this.sseStreamer.streamActionEvent(chatId, data)
                 break