java - Camel 延迟优先于任何重新交付政策

这是简化的ftp轮询机制。

<camelContext id="Fetcher" xmlns="http://camel.apache.org/schema/blueprint">

    <redeliveryPolicyProfile id="redeliveryPolicy"
        redeliveryDelay="10000"
        maximumRedeliveries="-1" />

    <camel:route id="fetchFiles">
        <camel:from uri="ftp://10.20.30.40/From?username=user&password=RAW({{password}})&delay=3000" />
        <camel:to uri="log:input?showAll=true&level=INFO"/>
        <camel:to uri="file://incomingDirectory" />

        <onException redeliveryPolicyRef="msRedeliveryPolicy">
            <exception>java.lang.Exception</exception>
            <redeliveryPolicy logRetryAttempted="true" retryAttemptedLogLevel="WARN"/>
        </onException>
    </camel:route>

</camelContext>

  您认为失败会发生什么？ （延迟为3秒，
  redeliveryDelay是10秒。）
  
  答：它每3秒钟轮询一次，直到永远。


因此，让我们看一下文档。也许我需要这个

"repeatCount (scheduler)"

Specifies a maximum limit of number of fires. So if you set it to 1, the scheduler will only fire once. If you set it to 5, it will only fire five times. A value of zero or negative means fire forever.

Default: 0

不，它甚至不是有效的参数。那么为什么在文档中呢？

 Unknown parameters=[{repeatCount=5}]

好的，我想每3秒轮询一次。那么我如何告诉骆驼停止呢？让我们尝试将“ handled”设置为true吗？

<onException redeliveryPolicyRef="msRedeliveryPolicy">
    <exception>java.lang.Exception</exception>
    <redeliveryPolicy logRetryAttempted="true" retryAttemptedLogLevel="WARN"/>
    <handled><constant>true</constant></handled>
</onException>

没运气。仍然3秒。显然，甚至还没有到达重新交付部分。

有什么秘密？

最佳答案

事实是来自端点的错误不会由用户定义的路由处理（即上述设置中的fetchFiles）。因此，不涉及onException和redeliveryPolicy，因为它们仅影响属于用户定义路线的内容。

要控制从端点定义的使用者的行为，显而易见的方法是使用该组件中存在的选项。根据@Screwtape的建议，在您的情况下使用backoffErrorThreshold和backoffMultplier。

为什么文档中存在参数repeatCount，但参数无效？它可能在您的骆驼版本中不存在，并且Camel文档编写者忘记在文档中标记第一个存在的版本。