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
解决了
022020-05-24
相似问题