无法被路由的消息去了哪里?
无设置的情况下,无法路由(Routing key错误)的消息会被直接丢弃
解决方案:
将mandatory
设置为true
,并配合ReturnListener
,实现消息的回发
声明交换机时,指定备份的交换机
Map<String,Object> arguments = new HashMap<String,Object>();
arguments.put("alternate-exchange","备份交换机名");
无设置的情况下,无法路由(Routing key错误)的消息会被直接丢弃
解决方案:
将mandatory
设置为true
,并配合ReturnListener
,实现消息的回发
声明交换机时,指定备份的交换机
Map<String,Object> arguments = new HashMap<String,Object>();
arguments.put("alternate-exchange","备份交换机名");