开始
加一个重载,收到死信的时候要把死信保存起来。
消息的类型是Dead
死信的配置和死信的监听
新增配置类
把死信交换机,死信队列声明一下。死信的监听也声明一下。
队列、交换机和绑定都设置好了。都变成Bean交给Spring容器管理。框架里面的rabbitAdmin起来的时候,它会把这些交换机的设置都设置好。
类名改一下
添加死信的监听类
死信的消息不需要业务去监听了。框架监听就可以了。
ConditionalOnProperty加上这个注解,因为不是所有的服务都监听死信。有可能好几个微服务使用同一个rabbitMQ,也不需要所有的微服务都监听这个mq上的死信。我们需要一个可以配置的注册的内容。通过这个就设置是不是要监听这个死信。
如果不是死信的类就不需要监听。
重写onMessage方法
最后ack单挑确认。