RabbitTemplate的两段回调确认机制

ConfirmCallback是用来得知是否进入到交换机
ReturnCallback是获取未进入队列的回调信息，如果成功进入队列，不会进入这个回调方法。
注意要触发ReturnCallback，必须设置rabbitTemplate.setMandatory(true);

@Bean
public RabbitTemplate rabbitTemplate(CachingConnectionFactory factory) {
  // 开启消息进入Broker确认
  factory.setPublisherConfirmType(CachingConnectionFactory.ConfirmType.CORRELATED);
  // 开启消息未进入队列确认
  factory.setPublisherReturns(true);
  
  RabbitTemplate rabbitTemplate = new RabbitTemplate(factory);
  // 进入Broker时触发回调
  rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {
      @Override
      public void confirm(CorrelationData correlationData, boolean b, String s) {
        log.info("消息进入到broker，是否到交换机:correlationData({}),ack({}),cause({})", correlationData, b, s);
      }
  });
  
  // Mandatory：为true时,消息通过交换器无法匹配到队列会返回给生产者 并触发MessageReturn，为false时,匹配不到会直接被丢弃
  rabbitTemplate.setMandatory(true);
  // 消息未进入队列时触发回调
  rabbitTemplate.setReturnCallback(new RabbitTemplate.ReturnCallback() {
      @Override
      public void returnedMessage(Message message, int i, String s, String s1, String s2) {
        log.info("消息未进入队列:exchange({}),route({}),replyCode({}),replyText({}),message:{}",s1, s2, i, s, message);
      }
  });
}