@littlersmall 大神，我通過(guò)故意將Exchange名稱(chēng)寫(xiě)錯(cuò)，回調(diào)到了ComfirmCallback,ack為False，并且沒(méi)有跳到try｛｝Catch中，我打算將你的代碼寫(xiě)到項(xiàng)目里去
rabbitmq可靠發(fā)送的自動(dòng)重試機(jī)制http://www.itdecent.cn/p/4112d78a8753 接這篇 在上文中，主要實(shí)現(xiàn)了可靠模式的consumer。而可靠模式的sender實(shí)現(xiàn)的相對(duì)簡(jiǎn)略，主...
rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
if (!ack) {
log.info("send message failed: " + cause + correlationData.toString());
} else {
System.out.println("retryCache.del(correlationData.getId());");
}
});
大神，請(qǐng)問(wèn)這個(gè)方法的ack值為FALSE的情況下，
try {
rabbitTemplate.correlationConvertAndSend(message, new CorrelationData("generateId()"));/*generateId()*/
} catch (Exception e) {
能否捕捉到
}
rabbitmq可靠發(fā)送的自動(dòng)重試機(jī)制http://www.itdecent.cn/p/4112d78a8753 接這篇 在上文中，主要實(shí)現(xiàn)了可靠模式的consumer。而可靠模式的sender實(shí)現(xiàn)的相對(duì)簡(jiǎn)略，主...
