[BE/FIX] TranscodeStatusListener 큐 자동 선언 추가로 큐 미존재 시 애플리케이션 크래시 방지

src/main/java/app/handong/cms/listener/TranscodeStatusListener.java

@@ -1,10 +1,12 @@
 package app.handong.cms.listener;
 
-
 import app.handong.cms.service.NodeService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.context.annotation.Bean;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.amqp.core.Queue;
 import org.springframework.stereotype.Component;
 
 @Slf4j
@@ -18,11 +20,14 @@ public class TranscodeStatusListener {
     public void handleTranscodeStatus(TranscodeStatusMessage message) {
         try {
             log.info("📡⚡️ 트랜스코딩 상태 메시지 수신 - videoId: {}, status: {}, progress: {}", message.getVideoId(), message.getStatus(), message.getProgress());
-
             nodeService.updateVideoTranscodeStatus(message.getVideoId(), message.getStatus(), message.getProgress());
-
         } catch (Exception e) {
             log.error("❌ 트랜스코딩 상태 메시지 처리 실패", e);
         }
     }
+
+    @Bean
+    public Queue transcodeStatusQueue(@Value("${rabbitmq.queue.transcode-status}") String name) {
+        return new Queue(name, true);
+    }
 }

src/main/resources/application.yaml

@@ -24,6 +24,14 @@ spring:
     port: ${RABBITMQ_PORT}
     username: ${RABBITMQ_USERNAME}
     password: ${RABBITMQ_PASSWORD}
+    listener:
+      simple:
+        missing-queues-fatal: false
+        retry:
+          enabled: true               # (선택) 연결 재시도 활성화
+          initial-interval: 2000ms
+          max-attempts: 5
+          multiplier: 2.0
 
 cloud:
   aws: