[fix]:去掉SSE发送器中过时的代码,以免导致异常 【because "sendFailed" is null】

This commit is contained in:
jackshenonly committed 2024-06-07 14:51:02 +08:00
1 parent 2d1f8cd6db
commit 22666e1ffa
1 file changed
+1 -6
@@ -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);
}