sync模块修复

yangys

2024-04-01 a36d93e531c292240dc59cb8e712b2eca21a4066

 smart-man-boot/src/main/java/com/qianwen/smartman/modules/sync/message/sse/SseEmitterServer.java

@@ -17,7 +17,7 @@
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/sync/message/sse/SseEmitterServer.class */
public class SseEmitterServer {
    private static final Logger log = LoggerFactory.getLogger(SseEmitterServer.class);
    private static final Map<String, SseEmitter> SSE_CACHE = new ConcurrentHashMap();
    private static final Map<String, SseEmitter> SSE_CACHE = new ConcurrentHashMap<>();

    public SseEmitter createSseConnect(String clientId) {
        if (StrUtil.isEmpty(clientId)) {
@@ -69,7 +69,7 @@
    }

    public void sendAll(Object data, String eventId) {
        SSE_CACHE.forEach(k, v -> {
        SSE_CACHE.forEach((k, v) -> {
            sendMsg(k, data, eventId);
        });
    }