| | |
| | | .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); |
| | | } |
| | | } |
| | |
| | | data.put("durationMs", step.getDurationMs() != null ? step.getDurationMs() : 0); |
| | | data.put("retryCount", step.getRetryCount() != null ? step.getRetryCount() : 0); |
| | | data.put("errorMessage", step.getErrorMessage() != null ? step.getErrorMessage() : ""); |
| | | data.put("successMessage", step.getSuccessMessage() != null ? step.getSuccessMessage() : ""); |
| | | return data; |
| | | } |
| | | |