1. 메시지가 원래 큐에 인입
2. TTL 만료 / Reject / 큐 길이 초과 중 하나 발생
3. RabbitMQ가 해당 메시지를 DLX(Dead Letter Exchange)로 전달
4. DLX가 미리 지정된 DLQ(Dead Letter Queue)로 라우팅
5. DLQ의 전용 소비자가 메시지를 재처리, 로깅, 또는 알림 발송

rabbitmqctl set_policy ${정책이름} ${큐이름정규식} \
  '{"dead-letter-exchange":"${DLX_익스체인지_이름}"}' \
  --apply-to ${queues|exchanges|all}

1. 메시지를 "대기 큐"에 발행 (TTL 설정, 소비자 없음)
2. TTL 만료 → DLX로 전달
3. DLX가 "실제 처리 큐"로 라우팅
4. 소비자가 처리 큐에서 메시지를 소비

// 대기 큐 선언: TTL 30초 + DLX 연결, 소비자 없음
Map<String, Object> waitArgs = new HashMap<>();
waitArgs.put("x-message-ttl", 30000);           // 30초 후 만료
waitArgs.put("x-dead-letter-exchange", "work.exchange");  // 만료 시 DLX로 전달
waitArgs.put("x-dead-letter-routing-key", "work.key");
channel.queueDeclare("wait.queue", true, false, false, waitArgs);

// 실제 처리 큐 선언: 소비자가 여기서 메시지를 소비
channel.queueDeclare("work.queue", true, false, false, null);
channel.queueBind("work.queue", "work.exchange", "work.key");

# 플러그인 디렉토리 확인
rabbitmq-plugins directories -s

# 플러그인 다운로드
wget https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases/download/v4.1.0/rabbitmq_delayed_message_exchange-4.1.0.ez

# 플러그인 활성화
rabbitmq-plugins enable rabbitmq_delayed_message_exchange

public class DelayQueueMain {

    private static final String DELAYED_EXCHANGE = "delay.exchange";
    private static final String DELAYED_QUEUE = "delay.queue";
    private static final String ROUTING_KEY = "delay.routingkey";

    @Bean
    public CustomExchange delayExchange() {
        Map<String, Object> args = Map.of("x-delayed-type", "direct");
        return new CustomExchange(DELAYED_EXCHANGE, "x-delayed-message", true, false, args);
    }

    @Bean
    public Queue delayQueue() {
        return new Queue(DELAYED_QUEUE, true);
    }

    @Bean
    public Binding binding(Queue delayQueue, CustomExchange delayExchange) {
        return BindingBuilder.bind(delayQueue).to(delayExchange).with(ROUTING_KEY).noargs();
    }

    @Bean
    public CommandLineRunner testSend(RabbitTemplate rabbitTemplate) {
        return args -> {
            String message = "테스트 메시지";
            MessageProperties props = new MessageProperties();
            props.setHeader("x-delay", 3000); // 3초 지연 (밀리초 단위)
            Message msg = new Message(message.getBytes(), props);
            rabbitTemplate.send(DELAYED_EXCHANGE, ROUTING_KEY, msg);
            System.out.println("지연 메시지 전송 완료");
        };
    }
}