Skip to content

Commit a32583f

Browse files
committed
test: Consumer 테스트에 RankingAggregator Mock 추가
Consumer에 RankingAggregator 의존성이 추가되면서 테스트 코드도 함께 수정 필요 - CatalogEventConsumerTest: RankingAggregator Mock 추가 - OrderEventConsumerTest: RankingAggregator Mock 추가
1 parent dc98a4c commit a32583f

2 files changed

Lines changed: 10 additions & 0 deletions

File tree

apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/CatalogEventConsumerTest.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99
import com.fasterxml.jackson.databind.ObjectMapper;
1010
import com.loopers.application.inbox.EventInboxService;
1111
import com.loopers.application.metrics.ProductMetricsService;
12+
import com.loopers.application.ranking.RankingAggregator;
1213
import java.util.HashMap;
1314
import java.util.Map;
1415
import org.apache.kafka.clients.consumer.ConsumerRecord;
@@ -37,6 +38,9 @@ class CatalogEventConsumerTest {
3738
@Mock
3839
private ProductMetricsService productMetricsService;
3940

41+
@Mock
42+
private RankingAggregator rankingAggregator;
43+
4044
private CatalogEventConsumer catalogEventConsumer;
4145

4246
private final ObjectMapper objectMapper = new ObjectMapper();
@@ -47,6 +51,7 @@ void setUp() {
4751
catalogEventConsumer = new CatalogEventConsumer(
4852
eventInboxService,
4953
productMetricsService,
54+
rankingAggregator,
5055
null, // DeadLetterQueueService - 단위 테스트에서 사용하지 않음
5156
objectMapper
5257
);

apps/commerce-streamer/src/test/java/com/loopers/interfaces/consumer/OrderEventConsumerTest.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
import com.fasterxml.jackson.databind.ObjectMapper;
1212
import com.loopers.application.inbox.EventInboxService;
1313
import com.loopers.application.metrics.ProductMetricsService;
14+
import com.loopers.application.ranking.RankingAggregator;
1415
import java.math.BigDecimal;
1516
import java.util.HashMap;
1617
import java.util.Map;
@@ -40,6 +41,9 @@ class OrderEventConsumerTest {
4041
@Mock
4142
private ProductMetricsService productMetricsService;
4243

44+
@Mock
45+
private RankingAggregator rankingAggregator;
46+
4347
private OrderEventConsumer orderEventConsumer;
4448

4549
private final ObjectMapper objectMapper = new ObjectMapper();
@@ -50,6 +54,7 @@ void setUp() {
5054
orderEventConsumer = new OrderEventConsumer(
5155
eventInboxService,
5256
productMetricsService,
57+
rankingAggregator,
5358
null, // DeadLetterQueueService - 단위 테스트에서 사용하지 않음
5459
objectMapper
5560
);

0 commit comments

Comments
 (0)