Search code examples
rabbitmqdead-letter

RabbitMQ dead letter exchange/queue


I don't quite understand the dead letter exchange/queue. the online document says:

republished to another exchange when any of the following events occur:
    The message is rejected (basic.reject or basic.nack) with requeue=false,
    The TTL for the message expires; or
    The queue length limit is exceeded.

does that mean when those event happen the messages will be automatically move to the dead letter queue? or I have to specifically in my code to move those 'dead' messages to that DLQ?

Also how do i setup a DLX/DLQ for my normal queue? say when message in my normal queue failed/expired, then it moves to DLX/DLQ?


Solution

  • Here is an complete example:

    public class DXtest {
        public static void main(String[] argv)
                throws IOException,
                InterruptedException, TimeoutException {
    
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
    
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();
            channel.exchangeDeclare("my.exchange", "fanout");
    
            Map<String, Object> args = new HashMap<String, Object>();
            args.put("x-dead-letter-exchange", "my.exchange");
            args.put("x-max-length", 2);
            channel.queueDeclare("myqueue", false, false, false, args); // here you setup your queue, 
    //for example with x-max-length, when the limit is reach, the message head message queue will be redirect  
    //to the my.exchange and then to my-dead-letter-queue
    
    
    
            channel.queueDeclare("my-dead-letter-queue", false, false, false, null);
            channel.queueBind("my-dead-letter-queue","my.exchange","");
    
    
            Consumer consumer = new DefaultConsumer(channel) {
                @Override
                public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
                        throws IOException {
                    String message = new String(body, "UTF-8");
                    System.out.println(" [x] Message   '" + message + "'" + new Date());
                }
            };
            channel.basicConsume("my-dead-letter-queue", true, consumer);
    
        }
    
    }