如何在Camel中延迟重试

Question

我有兴趣在 Camel 中使用 RedeliveryPolicy 在返回特定异常时重试将消息重新传递到端点。但我似乎找不到很多如何配置它的示例。

目前我正在尝试：

    from("direct:entry")
            .onException(ResourceNotFoundException.class)
                .redeliveryPolicy(new RedeliveryPolicy().delayPattern("delayPattern=0:" + aocmDelay + ",10:1000;15:2000:19:10000"))
                .handled(true)
            .end()
            .to("direct:destination");

我的目标端点因 ResourceNotFoundException 失败，但未调用 onException 处理，并且重新传递未生效。对我做错了什么有什么想法吗？

Answer 1

您需要设置重新投递策略的单个属性。

from("direct:entry")
    .onException(ResourceNotFoundException.class)
        .maximumRedeliveries(20)
        .delayPattern("1:2000;10:1000;15:2000;19:10000")
        .handled(true)
        .end()
    .to("direct:destination");

补充评论：

• 您需要定义最大重新传递尝试次数（如果在其他地方未定义），否则将使用默认值零
• 在延迟模式中你有两个拼写错误
  delayPattern=0:" + aocmDelay + ",10:1000;15:2000:19:10000
________________________________;_______________;________
• 重新投递计数从 开始1，如果您定义0:1000;1:5000第一次重新投递延迟五秒而不是一秒