🐞 BugFix/#121 - Spring Data Redis는 기본 키(@id) 기반 삭제만 지원해서 발생하는 버그

9oormthon-univ · Nov 23, 2024 · 48eafff · 48eafff
1 parent e8ccd5f
commit 48eafff
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/src/main/java/com/daon/onjung/core/repository/redis/ScheduledEventJobRepository.java b/src/main/java/com/daon/onjung/core/repository/redis/ScheduledEventJobRepository.java
@@ -6,10 +6,11 @@
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
+import java.util.Optional;
 
 @Repository
 public interface ScheduledEventJobRepository extends CrudRepository<ScheduledEventJob, String> {
     @NotNull List<ScheduledEventJob> findAll();
 
-    void deleteByEventId(Long eventId);
+    Optional<ScheduledEventJob> findByEventId(Long eventId);
 }
diff --git a/...daon/onjung/event/application/controller/consumer/EventSchedulerConsumerV1Controller.java b/...daon/onjung/event/application/controller/consumer/EventSchedulerConsumerV1Controller.java
@@ -21,7 +21,8 @@ public void execute(JobExecutionContext context) throws JobExecutionException {
         Long eventId = context.getJobDetail().getJobDataMap().getLong("eventId");
 
         // eventId를 통해 ScheduledEventJob을 삭제
-        scheduledEventJobRepository.deleteByEventId(eventId);
+        scheduledEventJobRepository.findByEventId(eventId)
+                .ifPresent(scheduledEventJobRepository::delete);
         log.info("ScheduledEventJob 삭제 완료. eventId: {}", eventId);
 
         processCompletedEventUseCase.execute(eventId);