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); }