| | |
| | | .name(eventName) |
| | | .data(createMessage("", data))); |
| | | } catch (IOException e) { |
| | | log.warn("发送SSE消息失败: taskId={}, event={}", taskId, eventName, e); |
| | | // 客户端断开连接是正常情况,使用DEBUG级别 |
| | | if (e instanceof org.apache.catalina.connector.ClientAbortException) { |
| | | log.debug("客户端断开SSE连接: taskId={}, event={}", taskId, eventName); |
| | | } else { |
| | | log.warn("发送SSE消息失败: taskId={}, event={}", taskId, eventName, e); |
| | | } |
| | | toRemove.add(emitter); |
| | | } |
| | | } |
| | |
| | | .name(eventName) |
| | | .data(createMessage("", data))); |
| | | } catch (IOException e) { |
| | | log.warn("发送SSE消息失败: event={}", eventName, e); |
| | | // 客户端断开连接是正常情况,使用DEBUG级别 |
| | | if (e instanceof org.apache.catalina.connector.ClientAbortException) { |
| | | log.debug("客户端断开SSE连接: event={}", eventName); |
| | | } else { |
| | | log.warn("发送SSE消息失败: event={}", eventName, e); |
| | | } |
| | | toRemove.add(emitter); |
| | | } |
| | | } |