diff --git a/src/main/java/app/handong/cms/listener/TranscodeStatusListener.java b/src/main/java/app/handong/cms/listener/TranscodeStatusListener.java index 17936bd2..ee03eff7 100644 --- a/src/main/java/app/handong/cms/listener/TranscodeStatusListener.java +++ b/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); + } } diff --git a/src/main/resources/application.yaml b/src/main/resources/application.yaml index 09b8a960..3d5d0df9 100644 --- a/src/main/resources/application.yaml +++ b/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: