Skip to content

Commit 1011455

Browse files
committed
fix: SSE 수정
- 요청 부분만 카프카로 컨트롤
1 parent 72c17a6 commit 1011455

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -102,9 +102,9 @@ 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);
110110
} catch (EmotionRecordNotFoundException e) {

0 commit comments

Comments
 (0)