Feat: 사용자가 접속되지 않은 서버이면 broadcast 스킵

f-lab-edu · Feb 20, 2024 · 2f274c2 · 2f274c2
1 parent 03c294d
commit 2f274c2
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/main/java/com/stoury/config/sse/SseEmitters.java b/src/main/java/com/stoury/config/sse/SseEmitters.java
@@ -39,7 +39,10 @@ private SseEmitter chatRoomEmitter(Long roomId) {
     public void broadcast(Long roomId, ChatMessageResponse chatMessage) {
         Long roomIdNotNull = Objects.requireNonNull(roomId, ROOM_ID_NULL_MESSAGE);
 
-        SseEmitter emitter = get(roomIdNotNull);
+        SseEmitter emitter = chatRoomEmitters.get(roomIdNotNull);
+        if (emitter == null) {
+            return;
+        }
 
         for (int i = 1; i <= MAX_RETRY; i++) {
             try {