注意:备份交换机一定要选择fanout类型,因为原交换机转入备份交换机时并不会指定路由键
注意:这里是要和备份交换机绑定
public static final String EXCHANGE_DIRECT_BACKUP = "exchange.direct.order.backup";
public static final String QUEUE_NAME_BACKUP = "queue.order.backup";
@RabbitListener(bindings = @QueueBinding(
value = @Queue(value = QUEUE_NAME_BACKUP, durable = "true"),
exchange = @Exchange(value = EXCHANGE_DIRECT_BACKUP),
key = {""}
))
public void processMessageBackup(String dateString,
Message message,
Channel channel) {
log.info("BackUp: " + dateString);
}- 启动消费者端
- 发送消息,但是路由键不对,于是转入备份交换机










