From d1a7f3f3417ebed8870ac7ecd607964df5ebf5a1 Mon Sep 17 00:00:00 2001 From: JIN-076 Date: Tue, 25 Jun 2024 00:58:56 +0900 Subject: [PATCH] =?UTF-8?q?[FEAT]=20=EC=8B=A4=ED=8C=A8=ED=95=9C=20?= =?UTF-8?q?=EC=9D=B4=EB=B2=A4=ED=8A=B8=EB=A5=BC=20=EC=9E=AC=EB=B0=9C?= =?UTF-8?q?=ED=96=89=ED=95=98=EB=8A=94=20=EC=8A=A4=EC=BC=80=EC=A4=84?= =?UTF-8?q?=EB=9F=AC=20Cron=EC=8B=9D=20=EB=B3=80=EA=B2=BD,=20=EB=B6=88?= =?UTF-8?q?=ED=95=84=EC=9A=94=ED=95=9C=20=EC=8A=A4=EC=BC=80=EC=A4=84?= =?UTF-8?q?=EB=9F=AC=20=EC=A0=9C=EA=B1=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../properties/kafka/MessageProducer.java | 2 +- .../log/application/CacheWarmingService.java | 35 ------------------- .../outbox/application/OutboxProcessor.java | 4 +-- 3 files changed, 3 insertions(+), 38 deletions(-) delete mode 100644 src/main/java/io/oeid/mogakgo/domain/log/application/CacheWarmingService.java 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