From a7a17667e41ed0c5fd24b0760c803f0406af4cd7 Mon Sep 17 00:00:00 2001 From: Ziin Date: Mon, 28 Jul 2025 19:20:11 +0800 Subject: [PATCH] =?UTF-8?q?1.=E5=9C=A8=E6=AF=8F=E4=B8=80=E6=AC=A1Sse?= =?UTF-8?q?=E5=8F=91=E6=B6=88=E6=81=AF=E5=89=8D=E5=8F=91=E9=80=81=20Start?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../yupi/springbootinit/service/impl/HostInfoServiceImpl.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java b/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java index 0b7c431..fc9975a 100644 --- a/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java +++ b/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java @@ -61,6 +61,8 @@ public class HostInfoServiceImpl extends ServiceImpl i NewHosts sseConnectConfirmInfo = newHosts.get(0); SseEmitter sseEmitter = SseEmitterUtil.getSseEmitter(sseConnectConfirmInfo.getTenantId().toString() + "-" + sseConnectConfirmInfo.getUserId().toString()); if (sseEmitter != null) { + NewHosts forChannelInfo = newHosts.get(0); + SseEmitterUtil.sendMessage(forChannelInfo.getTenantId().toString()+"-"+forChannelInfo.getUserId().toString(),"start"); newHosts.forEach(newHost -> { SseEmitterUtil.sendMessage(newHost.getTenantId().toString()+"-"+newHost.getUserId().toString(), JsonUtils.toJsonString(newHost));