4e9b0a134a4c

@littlersmall 大神，我通过故意将Exchange名称写错，回调到了ComfirmCallback,ack为False，并且没有跳到try｛｝Catch中，我打算将你的代码写到项目里去

rabbitmq可靠发送的自动重试机制

http://www.jianshu.com/p/4112d78a8753 接这篇 在上文中，主要实现了可靠模式的consumer。而可靠模式的sender实现的相对简略，主...

littlersmall

63941 44 89

4e9b0a134a4c

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可靠发送的自动重试机制

http://www.jianshu.com/p/4112d78a8753 接这篇 在上文中，主要实现了可靠模式的consumer。而可靠模式的sender实现的相对简略，主...

littlersmall

63941 44 89