jiazhizhong/higress
1
0
Fork 0
mirror of https://github.com/alibaba/higress.git synced 2026-06-09 20:57:32 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(mcp-session): send SSE endpoint event via local goroutine InjectData (#3567)

Browse Source
This commit is contained in:
Damos chen
2026-03-05 20:17:16 +08:00
committed by GitHub
parent aa502e7e62
commit 13b808c1e4
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
plugins/golang-filter/mcp-session/common/sse.go
View File

@@ -140,10 +140,16 @@ func (s *SSEServer) HandleSSE(cb api.FilterCallbackHandler, stopChan chan struct
// Send the initial endpoint event // Send the initial endpoint event
initialEvent := fmt.Sprintf("event: endpoint\ndata: %s\n\n", messageEndpoint) initialEvent := fmt.Sprintf("event: endpoint\ndata: %s\n\n", messageEndpoint)
err = s.redisClient.Publish(channel, initialEvent) go func() {
if err != nil { defer func() {
api.LogErrorf("Failed to send initial event: %v", err) if r := recover(); r != nil {
} api.LogErrorf("Failed to send initial event: %v", r)
}
}()
defer cb.EncoderFilterCallbacks().RecoverPanic()
api.LogDebugf("SSE Send message: %s", initialEvent)
cb.EncoderFilterCallbacks().InjectData([]byte(initialEvent))
}()
// Start health check handler // Start health check handler
go func() { go func() {