From 049f48e56cc22ba0e3c4e4e4301ad8aeb00b5a18 Mon Sep 17 00:00:00 2001 From: senna Date: Wed, 5 Feb 2025 23:20:36 +0900 Subject: [PATCH] =?UTF-8?q?refactor:=20=EC=9E=90=EB=8F=99=20=EB=A7=A4?= =?UTF-8?q?=EC=B9=AD=20=EB=B0=A9=20=EC=83=9D=EC=84=B1=20=EC=8B=9C=20?= =?UTF-8?q?=EC=9D=B4=EB=B2=A4=ED=8A=B8=20=EB=B0=9C=ED=96=89=20=EC=A0=84=20?= =?UTF-8?q?=EC=83=9D=EC=84=B1=EB=90=9C=20=EB=B0=A9=20DB=EC=97=90=20?= =?UTF-8?q?=EB=84=A3=EB=8F=84=EB=A1=9D=20=EC=88=98=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../matching/event/service/kafka/AutoMatchingConsumer.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/gachtaxi/domain/matching/event/service/kafka/AutoMatchingConsumer.java b/src/main/java/com/gachtaxi/domain/matching/event/service/kafka/AutoMatchingConsumer.java index c4d9c1b1..ae56d5f0 100644 --- a/src/main/java/com/gachtaxi/domain/matching/event/service/kafka/AutoMatchingConsumer.java +++ b/src/main/java/com/gachtaxi/domain/matching/event/service/kafka/AutoMatchingConsumer.java @@ -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();