From d7416be841ea46fe2786bb0bfb295af377265e97 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=86=B7=E5=86=B7?= <2270033969@qq.com>
Date: Thu, 21 Mar 2024 10:06:45 +0800
Subject: [PATCH] =?UTF-8?q?:zap:=20=E4=BC=98=E5=8C=96=20common-sse=20?=
 =?UTF-8?q?=E9=93=BE=E6=8E=A5=E6=88=90=E5=8A=9F=E5=A2=9E=E5=8A=A0=20pong?=
 =?UTF-8?q?=20=E6=B6=88=E6=81=AF=E8=BF=94=E5=9B=9E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../pig4cloud/pigx/common/sse/config/SseEmitterEndpoint.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/config/SseEmitterEndpoint.java b/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/config/SseEmitterEndpoint.java
index b39693c6c..397a81f1f 100644
--- a/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/config/SseEmitterEndpoint.java
+++ b/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/config/SseEmitterEndpoint.java
@@ -3,6 +3,7 @@ package com.pig4cloud.pigx.common.sse.config;
 import com.pig4cloud.pigx.common.security.util.SecurityUtils;
 import com.pig4cloud.pigx.common.sse.holder.SseEmitterHolder;
 import lombok.RequiredArgsConstructor;
+import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
@@ -20,6 +21,7 @@ import java.util.Objects;
 @RequestMapping("/sse")
 public class SseEmitterEndpoint {
 
+    @SneakyThrows
     @RequestMapping("/info")
     public SseEmitter info() {
         SseEmitter sseEmitter = new SseEmitter(0L);
@@ -39,6 +41,7 @@ public class SseEmitterEndpoint {
             log.error("MSG: SseConnectError | EmitterHash: {} |ID: {}", sseEmitter.hashCode(), SecurityUtils.getUser().getId());
         });
         SseEmitterHolder.addSseEmitter(SecurityUtils.getUser().getId(), sseEmitter);
+        sseEmitter.send("pong");
         return sseEmitter;
     }