diff --git a/src/main/java/io/oeid/mogakgo/core/properties/kafka/MessageProducer.java b/src/main/java/io/oeid/mogakgo/core/properties/kafka/MessageProducer.java index a54633f8..0af34d93 100644 --- a/src/main/java/io/oeid/mogakgo/core/properties/kafka/MessageProducer.java +++ b/src/main/java/io/oeid/mogakgo/core/properties/kafka/MessageProducer.java @@ -40,7 +40,7 @@ public void sendMessage(String topic, Event event) { // message is already committed in broker! // if execution fail itself, re-publishing processed message, - // and then, consumer will verify duplication with redis cache! + // and then, consumer will verify duplication! outboxTaskExecutor.execute(process(res)); } } diff --git a/src/main/java/io/oeid/mogakgo/domain/log/application/CacheWarmingService.java b/src/main/java/io/oeid/mogakgo/domain/log/application/CacheWarmingService.java deleted file mode 100644 index 792a5418..00000000 --- a/src/main/java/io/oeid/mogakgo/domain/log/application/CacheWarmingService.java +++ /dev/null @@ -1,35 +0,0 @@ -package io.oeid.mogakgo.domain.log.application; - -import io.oeid.mogakgo.domain.log.domain.entity.MessageLog; -import io.oeid.mogakgo.domain.log.infrastructure.MessageLogJpaRepository; -import jakarta.annotation.PostConstruct; -import java.util.List; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.scheduling.annotation.Scheduled; -import org.springframework.stereotype.Service; - -@Slf4j -@Service -@RequiredArgsConstructor -public class CacheWarmingService { - - private final MessageLogJpaRepository messageLogRepository; - private final CacheService cacheService; - - @PostConstruct - public void warnUpCache() { - List logList = messageLogRepository.findAll(); - - for (MessageLog log : logList) { - String eventId = log.getEventId(); - cacheService.cacheMessageId(eventId); - } - } - - @Scheduled(cron = "0 0 3 * * ?") - public void scheduleCacheWarming() { - warnUpCache(); - } - -} diff --git a/src/main/java/io/oeid/mogakgo/domain/outbox/application/OutboxProcessor.java b/src/main/java/io/oeid/mogakgo/domain/outbox/application/OutboxProcessor.java index 647bc205..8938c8a5 100644 --- a/src/main/java/io/oeid/mogakgo/domain/outbox/application/OutboxProcessor.java +++ b/src/main/java/io/oeid/mogakgo/domain/outbox/application/OutboxProcessor.java @@ -30,7 +30,7 @@ public class OutboxProcessor { private final OutboxJpaRepository outboxRepository; private final MessageProducer messageProducer; - @Scheduled(cron = "0 30 23 * * *") + @Scheduled(cron = "0 0 2 * * *") public void firstProcess() { // 첫 번째 이벤트 발행부터 실패한 케이스에 대한 re-publishing @@ -38,7 +38,7 @@ public void firstProcess() { republish(failedEvents, FIRST_TOPIC); } - @Scheduled(cron = "0 0 0 * * *") + @Scheduled(cron = "0 0 3 * * *") public void secondProcess() { // 두 번째 이벤트 발행만 실패한 케이스에 대한 re-publishing