- LikeKafkaEvent를 LikeCountEvent로 클래스명 변경

yeonjiyeon · yeonjiyeon · commit 6eaf1aa576e6 · 2025-12-31T22:04:53.000+09:00
- 이에 따른 컨슈머 및 퍼블리셔 구현체 수정
- OrderCreatedEvent, LikeEventOutboxHandler, LikeCountAggregateListener 패키지 구조 정리
diff --git a/apps/commerce-api/src/main/java/com/loopers/application/like/event/LikeEventOutboxHandler.java b/apps/commerce-api/src/main/java/com/loopers/application/like/event/LikeEventOutboxHandler.java
@@ -1,6 +1,5 @@
-package com.loopers.application.like;
+package com.loopers.application.like.event;
 
-import com.loopers.application.like.event.LikeCreatedEvent;
 import com.loopers.domain.event.OutboxService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
diff --git a/apps/commerce-api/src/main/java/com/loopers/application/order/event/OrderCreatedEvent.java b/apps/commerce-api/src/main/java/com/loopers/application/order/event/OrderCreatedEvent.java
@@ -1,4 +1,4 @@
-package com.loopers.application.order;
+package com.loopers.application.order.event;
 
 import com.loopers.domain.payment.PaymentType;
 import com.loopers.domain.user.User;
diff --git a/apps/commerce-api/src/main/java/com/loopers/application/product/event/LikeCountAggregateListener.java b/apps/commerce-api/src/main/java/com/loopers/application/product/event/LikeCountAggregateListener.java
@@ -1,8 +1,8 @@
-package com.loopers.application.product;
+package com.loopers.application.product.event;
 
 import com.loopers.application.event.FailedEventStore;
 import com.loopers.application.like.event.LikeCreatedEvent;
-import com.loopers.event.LikeKafkaEvent;
+import com.loopers.event.LikeCountEvent;
 import com.loopers.domain.product.ProductService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.context.ApplicationEventPublisher;
@@ -30,7 +30,7 @@ public void handleLikeCreatedEvent(LikeCreatedEvent event) {
     try {
       int updatedLikeCount = performAggregation(event);
 
-      eventPublisher.publishEvent(new LikeKafkaEvent(
+      eventPublisher.publishEvent(new LikeCountEvent(
           event.eventId(),
           event.productId(),
           updatedLikeCount
diff --git a/apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/LikeEventConsumer.java b/apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/LikeEventConsumer.java
@@ -1,7 +1,7 @@
 package com.loopers.interfaces.consumer;
 
 import com.loopers.domain.metrics.ProductMetricsService;
-import com.loopers.event.LikeKafkaEvent;
+import com.loopers.event.LikeCountEvent;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
@@ -20,7 +20,7 @@ public class LikeEventConsumer {
       topics = "catalog-events",
       groupId = "metrics-group"
   )
-  public void onMessage(ConsumerRecord<String, LikeKafkaEvent> record, Acknowledgment ack) {
+  public void onMessage(ConsumerRecord<String, LikeCountEvent> record, Acknowledgment ack) {
     try {
       log.info("이벤트 수신: {}", record.value().eventId());
 
diff --git a/modules/kafka/src/main/java/com/loopers/event/LikeCountEvent.java b/modules/kafka/src/main/java/com/loopers/event/LikeCountEvent.java
@@ -1,6 +1,6 @@
 package com.loopers.event;
 
-public record LikeKafkaEvent(
+public record LikeCountEvent(
    String eventId,
     Long productId,
     int currentLikeCount

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package com.loopers.application.order;`
	`1`	`+package com.loopers.application.order.event;`
`2`	`2`
`3`	`3`	`import com.loopers.domain.payment.PaymentType;`
`4`	`4`	`import com.loopers.domain.user.User;`