3.8）死信队列-死信交换机1

3.8）死信队列(死信交换机)

一:死信队列DLX(Dead-leater-exchange)

1.1）什么是死信?

就是在队列中的消息如果没有消费者消费，那么该消息就成为一个死信，那这个

消息被重新发送到另外一个exchange上的话，

那么后面这个exhcange就是死信队列

1.2)消息变成死信的几种情况

消息被拒绝：（basic.reject/basic.nack）并且requeue(重回队列)的属性设置为

public class DLX_CustomConsumer extends DefaultConsumer {

private Channel channel;

/**

* Constructs a new instance and records its association to the passed-in channel.

*

* @param channel the channel to which this consumer is attached

*/

public DLX_CustomConsumer(Channel channel) {

super(channel);

this.channel = channel;

{

System.out.println("为了测试死信队列,我们进行nack");

//把消息变为死信 通过nack 且requeue不进行重新发送

channel.basicNack(envelope.getDeliveryTag(),false,false);

}

}