hotfix: retry strategy update

Author: 2ghrms

src/main/java/com/haru/api/infra/redis/RedisReportConsumer.java

@@ -18,7 +18,6 @@
 public class RedisReportConsumer {
 
     private final StringRedisTemplate redisTemplate;
-    private final MoodTrackerReportService moodTrackerReportService;
 
     @Value("${queue-name}")
     private String QUEUE_KEY;
@@ -46,10 +45,6 @@ public void pollQueueEvery5Minutes() {
                     redisTemplate.opsForList().leftPush("REPORT_WORKER_QUEUE", id);
                     log.info("[RedisReportConsumer] REPORT_WORKER_QUEUE에 추가됨 → {}", id);
 
-                    // ZSET에서 제거
-                    redisTemplate.opsForZSet().remove(QUEUE_KEY, id);
-                    log.info("[RedisReportConsumer] ZSET({})에서 제거됨 → {}", QUEUE_KEY, id);
-
                 } catch (Exception e) {
                     log.error("[RedisReportConsumer] id={} 처리 중 에러", id, e);
                 }

src/main/java/com/haru/api/infra/redis/ReportWorker.java

@@ -3,6 +3,7 @@
 import com.haru.api.domain.moodTracker.service.MoodTrackerReportService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
@@ -19,7 +20,10 @@ public class ReportWorker {
     private final MoodTrackerReportService reportService;
     private final ExecutorService executor = Executors.newFixedThreadPool(5); // 5개 병렬 Worker
 
+    @Value("${queue-name}")
+    private String QUEUE_KEY;
     private static final String WORKER_QUEUE = "REPORT_WORKER_QUEUE";
+    private static final String FAILED_QUEUE = "REPORT_FAILED_QUEUE";
 
     @Scheduled(fixedDelay = 2000) // 2초마다 큐 확인
     public void consumeTasks() {
@@ -34,6 +38,9 @@ private void process(Long moodTrackerId) {
         try {
             reportService.generateAndUploadReportFileAndThumbnail(moodTrackerId);
             log.info("Report 생성 성공: {}", moodTrackerId);
+            // ZSET에서 제거
+            redisTemplate.opsForZSet().remove(QUEUE_KEY, moodTrackerId);
+            log.info("[RedisReportConsumer] ZSET({})에서 제거됨 → {}", QUEUE_KEY, moodTrackerId);
         } catch (Exception e) {
             log.error("Report 생성 실패 (재시도 예정): {}", moodTrackerId, e);
 
@@ -44,7 +51,7 @@ private void process(Long moodTrackerId) {
                 redisTemplate.opsForList().leftPush(WORKER_QUEUE, moodTrackerId.toString());
             } else {
                 log.error("재시도 한계 초과, 실패 큐로 이동: {}", moodTrackerId);
-                redisTemplate.opsForList().leftPush("REPORT_FAILED_QUEUE", moodTrackerId.toString());
+                redisTemplate.opsForList().leftPush(FAILED_QUEUE, moodTrackerId.toString());
             }
         }
     }