feat : dlq 도입

Author: EpicFn

src/main/java/org/tuna/zoopzoop/backend/global/mq/RabbitMQConfig.java

@@ -1,9 +1,6 @@
 package org.tuna.zoopzoop.backend.global.mq;
 
-import org.springframework.amqp.core.Binding;
-import org.springframework.amqp.core.BindingBuilder;
-import org.springframework.amqp.core.Queue;
-import org.springframework.amqp.core.TopicExchange;
+import org.springframework.amqp.core.*;
 import org.springframework.amqp.rabbit.connection.ConnectionFactory;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
@@ -17,21 +14,46 @@ public class RabbitMQConfig {
     private static final String QUEUE_NAME = "graph.update.queue";
     private static final String ROUTING_KEY = "graph.update.#";
 
+    private static final String DLQ_EXCHANGE_NAME = EXCHANGE_NAME + ".dlx";
+    private static final String DLQ_QUEUE_NAME = QUEUE_NAME + ".dlq";
+    private static final String DLQ_ROUTING_KEY = "graph.update.dlq";
+
     @Bean
     public TopicExchange exchange() {
         return new TopicExchange(EXCHANGE_NAME);
     }
 
     @Bean
     public Queue queue() {
-        return new Queue(QUEUE_NAME);
+        return QueueBuilder.durable(QUEUE_NAME)
+                .withArgument("x-dead-letter-exchange", DLQ_EXCHANGE_NAME) // 실패 시 메시지를 보낼 Exchange
+                .withArgument("x-dead-letter-routing-key", DLQ_ROUTING_KEY) // 실패 시 사용할 라우팅 키
+                .build();
     }
 
     @Bean
     public Binding binding(Queue queue, TopicExchange exchange) {
         return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);
     }
 
+    // ================= DLQ 인프라 구성 추가 ================= //
+
+    @Bean
+    public TopicExchange dlqExchange() {
+        return new TopicExchange(DLQ_EXCHANGE_NAME);
+    }
+
+    @Bean
+    public Queue dlqQueue() {
+        return new Queue(DLQ_QUEUE_NAME);
+    }
+
+    @Bean
+    public Binding dlqBinding(Queue dlqQueue, TopicExchange dlqExchange) {
+        return BindingBuilder.bind(dlqQueue).to(dlqExchange).with(DLQ_ROUTING_KEY);
+    }
+
+    // ================= DLQ 인프라 구성 추가 ================= //
     @Bean
     public MessageConverter messageConverter() {
         // 메시지를 JSON 형식으로 직렬화/역직렬화하는 컨버터

src/main/resources/application.yml

@@ -51,7 +51,12 @@ spring:
     port: 5672
     username: guest
     password: guest
-
+    listener:
+      simple:
+        retry:
+          enabled: true
+          initial-interval: 2000
+          max-attempts: 3
 springdoc:
   default-produces-media-type: application/json;charset=UTF-8
 logging:
@@ -60,6 +65,7 @@ logging:
     org.hibernate.orm.jdbc.extract: TRACE
     org.springframework.transaction.interceptor: TRACE
     com.back: DEBUG
+    org.springframework.retry: DEBUG
 
 server:
   port: 8080

src/test/java/org/tuna/zoopzoop/backend/domain/dashboard/extraComponent/GraphUpdateConsumerTest.java

@@ -1,12 +1,10 @@
 package org.tuna.zoopzoop.backend.domain.dashboard.extraComponent;
 
-import org.assertj.core.api.AbstractStringAssert;
 import org.junit.jupiter.api.*;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.jdbc.AutoConfigureTestDatabase;
 import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.annotation.DirtiesContext;
-import org.springframework.test.context.jdbc.Sql;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.support.TransactionTemplate;
 import org.tuna.zoopzoop.backend.domain.dashboard.dto.GraphUpdateMessage;