ReturnCallback和ConfirmCallback没有起作用

来源:4-14 RabbitMQ与SpringBoot2.0整合实战-2

慕斯卡8036547

2020-03-10

发送消息的时候什么都没打印,百度了下也没找到原因
以下是配置和代码
因为publisher-confirms: true好像被废弃了,所以用的publisher-confirm-type: correlated
publisher-returns: true
publisher-confirm-type: correlated
template:
mandatory: true

    public void sendOrder(Object order, Map<String,Object> properties) throws Exception {
        MessageHeaders messageHeaders=new MessageHeaders(properties);
        Message msg=MessageBuilder.createMessage(order,messageHeaders);
        template.setConfirmCallback((correlationData, ack, cause) -> {
            System.err.println("ack:" + ack);
            if (!ack) {
                System.out.println("异常处理");
            }
        });
        template.setReturnCallback((message, replyCode, replyText, exchange, routingKey) -> {
            System.out.println("========returnCallback=============");
            System.out.println("========returnCallback=============");
        });
        template.convertAndSend("order-exchange","order.*",msg);

    }
写回答

1回答

慕斯卡8036547

提问者

2020-03-10

解决了

0
2
慕斯卡8036547
回复
慕桂英4064416
我之前是因为一部分代码和老师的不一致,改为一致的就可以了,配置就在application.properties或者application.yml里配置
2020-05-24
共2条回复

RabbitMQ精讲 从0到1驾驭RabbitMQ应用与设计

从0到1,全面深入掌握RabbitMQ消息中间件技术

1460 学习 · 443 问题

查看课程