Spring Cloud 疑难杂症(7): Rabbitmq 只允许一个 callback

@Slf4j
@Component
public class RabbitSendConfirmCallBack implements RabbitTemplate.ConfirmCallback {
    @Override
    public void confirm(CorrelationData correlationData, boolean ack, String cause) {
        if (ack) {
            log.error("├ [Rabbitmq 发送] 确认成功cause" + cause);
        } else {
            //处理丢失的消息
            log.error("├ [Rabbitmq 发送] 确认失败:" + correlationData.getId() + "#cause" + cause);
        }
    }
}

@Slf4j
@Component
public class RabbitSendReturnCallback implements RabbitTemplate.ReturnCallback {
    @Override
    public void returnedMessage(Message message, int replyCode, String replyText,
                                String exchange, String routingKey) {
        log.error("├ [Rabbitmq 发送] 确认后回调return--message:"+new String(message.getBody())+",replyCode:"+replyCode+"," +
                "replyText:"
                +replyText+",exchange:"+exchange+",routingKey:"+routingKey);
    }
}

this.rabbitTemplate.setReturnCallback(rabbitSendReturnCallback);
this.rabbitTemplate.setConfirmCallback(rabbitSendConfirmCallBack);