Skip to content

Commit 58bc819

Browse files
committed
fix: SSE 수정
- 연결종료 & 타임아웃 로그 설정
1 parent 3f2ab9f commit 58bc819

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

src/main/java/org/dfbf/soundlink/domain/alert/controller/AlertController.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ public class AlertController {
2121
public SseEmitter subscribe(
2222
@AuthenticationPrincipal Long id,
2323
@RequestHeader(value = "Last-Event-ID", required = false, defaultValue = "") String lastEventId) {
24-
System.out.println("id = " + id);
2524
return alertService.connectAlarm(id, lastEventId);
2625
}
2726

src/main/java/org/dfbf/soundlink/domain/alert/service/AlertService.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -76,8 +76,14 @@ public SseEmitter connectAlarm(Long id, String lastEventId) {
7676
// SseEmitter 생성
7777
SseEmitter sseEmitter = alertRepository.save(emitterId, new SseEmitter(DEFAULT_TIMEOUT));
7878

79-
sseEmitter.onCompletion(() -> alertRepository.delete(id, emitterId)); // 연결 종료 시 처리
80-
sseEmitter.onTimeout(() -> alertRepository.delete(id, emitterId)); // 타임아웃 시 처리
79+
sseEmitter.onCompletion(() -> {
80+
log.error("[연결종료 로그] {}", emitterId);
81+
alertRepository.delete(id, emitterId);
82+
}); // 연결 종료 시 처리
83+
sseEmitter.onTimeout(() -> {
84+
log.error("[타임아웃 로그] {}", emitterId);
85+
alertRepository.delete(id, emitterId);
86+
}); // 타임아웃 시 처리
8187

8288
try {
8389
log.info("아아 알림 테스트 {}", emitterId);

0 commit comments

Comments
 (0)