SSE消息推送模块增加连接已知问题修复

pull/135/head
diant 2023-07-19 09:39:54 +08:00
parent d77945a427
commit 6753cfb3e3
1 changed files with 3 additions and 1 deletions

View File

@ -138,7 +138,9 @@ public class DevSseCacheUtil {
}
Map<String,Object> map = new ConcurrentHashMap<>();
map.put(DevSseEmitterParameterEnum.EMITTER.getValue(),emitter);
map.put(DevSseEmitterParameterEnum.FUTURE.getValue(), future);
if(future!=null){
map.put(DevSseEmitterParameterEnum.FUTURE.getValue(), future);
}
map.put(DevSseEmitterParameterEnum.LOGINID.getValue(), loginId);
sseCache.put(clientId, map);
}