apache-camel - 在达到骆驼最大重新交付的阈值后执行任务

Question

我使用骆驼重试在我的代码中实现了重试功能。它将重试最多五次。

onException(Exception.class)
    .maximumRedeliveries(5)
    .retryAttemptedLogLevel(LoggingLevel.WARN)
    .backOffMultiplier(5)
    .maximumRedeliveryDelay(5)
    .useExponentialBackOff();

现在我想在达到阈值而不是抛出异常时调用自定义方法。我怎样才能做到这一点？

Answer 1

这是死信通道 EIP 模式的确切用例。我建议将您的onException块转换为errorHandler并使用deadLetterChannel构建器。

errorHandler(
        deadLetterChannel("direct:redeliveryExhausted")
                .maximumRedeliveries(5)
                .retryAttemptedLogLevel(LoggingLevel.WARN)
                .backOffMultiplier(5)
                .maximumRedeliveryDelay(5)
                .useExponentialBackOff()
);

from("direct:redeliveryExhausted")
        .log("I am going to handle non-deliverable message")
        .log("Because of this exception: ${exception}")
        .to("log:failed");

Answer 2

您可以将其设置handled-flag为 true，然后调用您的自定义 bean。

onException(Exception.class)
    .maximumRedeliveries(5)
    .retryAttemptedLogLevel(LoggingLevel.WARN)
    .backOffMultiplier(5)
    .maximumRedeliveryDelay(5)
    .useExponentialBackOff()
    .handled(true)
    .to("bean:myCustomBean");