fix 修复 sse关闭 用户id或token为空报错问题

dev
疯狂的狮子Li 11 months ago
parent c930074184
commit 52734c48d0

@ -65,6 +65,9 @@ public class SseEmitterManager {
* @param token * @param token
*/ */
public void disconnect(Long userId, String token) { public void disconnect(Long userId, String token) {
if (userId == null || token == null) {
return;
}
Map<String, SseEmitter> emitters = USER_TOKEN_EMITTERS.get(userId); Map<String, SseEmitter> emitters = USER_TOKEN_EMITTERS.get(userId);
if (MapUtil.isNotEmpty(emitters)) { if (MapUtil.isNotEmpty(emitters)) {
try { try {

Loading…
Cancel
Save