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