|
|
|
@ -70,7 +70,9 @@ public class SseEmitterManager {
|
|
|
|
Map<String, SseEmitter> emitters = USER_TOKEN_EMITTERS.get(userId);
|
|
|
|
Map<String, SseEmitter> emitters = USER_TOKEN_EMITTERS.get(userId);
|
|
|
|
if (emitters != null) {
|
|
|
|
if (emitters != null) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
emitters.get(token).send(SseEmitter.event().comment("disconnected"));
|
|
|
|
SseEmitter sseEmitter = emitters.get(token);
|
|
|
|
|
|
|
|
sseEmitter.send(SseEmitter.event().comment("disconnected"));
|
|
|
|
|
|
|
|
sseEmitter.complete();
|
|
|
|
} catch (Exception ignore) {
|
|
|
|
} catch (Exception ignore) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
emitters.remove(token);
|
|
|
|
emitters.remove(token);
|
|
|
|
|