240 发简信
IP属地:广东
  • @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实现的相对简略,主...