Skip to content

Commit 112c774

Browse files
committed
fix: SSE 수정
- catch 수정
1 parent 8300262 commit 112c774

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

src/main/java/org/dfbf/soundlink/domain/chat/service/ChatRoomService.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -102,11 +102,14 @@ public ResponseResult saveRequestToRedis(Long requestUserId, Long emotionRecordI
102102
User requestUser = userRepository.findByUserIdWithCache(requestUserId)
103103
.orElseThrow(UserNotFoundException::new);
104104
AlertChatRequest alertChatRequest = new AlertChatRequest(emotionRecordId, requestUser.getNickname());
105-
Alert alert = alertService.createAlert(responseUserId, "alarm", alertChatRequest);
106-
kafkaProducer.send(TOPIC, alert);
107-
// alertService.send(responseUserId, "alarm", alertChatRequest);
105+
// Alert alert = alertService.createAlert(responseUserId, "alarm", alertChatRequest);
106+
// kafkaProducer.send(TOPIC, alert);
107+
alertService.send(responseUserId, "alarm", alertChatRequest);
108108

109109
return new ResponseResult(ErrorCode.SUCCESS);
110+
} catch (IllegalArgumentException e) {
111+
log.info(e.getMessage());
112+
return new ResponseResult(ErrorCode.SUCCESS, "요청은 갔지만, 상대방의 SSE가 없어 알림이 전송되지 않았습니다.");
110113
} catch (EmotionRecordNotFoundException e) {
111114
return new ResponseResult(ErrorCode.FAIL_TO_FIND_EMOTION_RECORD, e.getMessage());
112115
} catch (UserNotFoundException e) {

0 commit comments

Comments
 (0)