@littlersmall 大神,我通过故意将Exchange名称写错,回调到了ComfirmCallback,ack为False,并且没有跳到try{}Catch中,我打算将你的代码写到项目里去
rabbitmq可靠发送的自动重试机制//www.greatytc.com/p/4112d78a8753 接这篇 在上文中,主要实现了可靠模式的consumer。而可靠模式的sender实现的相对简略,主...
@littlersmall 大神,我通过故意将Exchange名称写错,回调到了ComfirmCallback,ack为False,并且没有跳到try{}Catch中,我打算将你的代码写到项目里去
rabbitmq可靠发送的自动重试机制//www.greatytc.com/p/4112d78a8753 接这篇 在上文中,主要实现了可靠模式的consumer。而可靠模式的sender实现的相对简略,主...
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可靠发送的自动重试机制//www.greatytc.com/p/4112d78a8753 接这篇 在上文中,主要实现了可靠模式的consumer。而可靠模式的sender实现的相对简略,主...