From 22666e1ffa12774ebf9038fcd98b9c008129e953 Mon Sep 17 00:00:00 2001 From: jackshenonly <253170334@qq.com> Date: Fri, 7 Jun 2024 14:51:02 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=EF=BC=9A=E5=8E=BB=E6=8E=89SSE=E5=8F=91?= =?UTF-8?q?=E9=80=81=E5=99=A8=E4=B8=AD=E8=BF=87=E6=97=B6=E7=9A=84=E4=BB=A3?= =?UTF-8?q?=E7=A0=81=EF=BC=8C=E4=BB=A5=E5=85=8D=E5=AF=BC=E8=87=B4=E5=BC=82?= =?UTF-8?q?=E5=B8=B8=20=20=E3=80=90because=20"sendFailed"=20is=20null?= =?UTF-8?q?=E3=80=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pigx/common/sse/config/SseEmitterMessageSender.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/config/SseEmitterMessageSender.java b/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/config/SseEmitterMessageSender.java index c3a4b5922..cee119b5d 100644 --- a/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/config/SseEmitterMessageSender.java +++ b/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/config/SseEmitterMessageSender.java @@ -39,12 +39,7 @@ public class SseEmitterMessageSender { return false; } - Object sendFailed = ReflectUtil.getFieldValue(sseEmitter, "sendFailed"); - if ((boolean) sendFailed) { - log.error("[send] sseEmitter 已经关闭"); - SseEmitterHolder.removeSseEmitter(sseEmitter); - return false; - } + try { sseEmitter.send(message); }