Skip to content

Commit

Permalink
refactor: 자동 매칭 방 생성 시 이벤트 발행 전 생성된 방 DB에 넣도록 수정
Browse files Browse the repository at this point in the history
  • Loading branch information
soyesenna committed Feb 5, 2025
1 parent b94617a commit 049f48e
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -32,10 +32,12 @@ public void onMatchRoomCreated(MatchRoomCreatedEvent event, Acknowledgment ack)
try {
log.info("[KAFKA CONSUMER] Received MatchRoomCreatedEvent: {}", event);

MatchRoomCreatedEvent createdEvent = this.matchingRoomService.createMatchingRoom(event);

this.sseService.sendToClient(
event.roomMasterId(),
"MATCH_ROOM_CREATED",
this.matchingRoomService.createMatchingRoom(event)
createdEvent
);

ack.acknowledge();
Expand Down

0 comments on commit 049f48e

Please sign in to comment.