Apache Camel中的无限循环

Question

我需要创建一个路由，它会在迭代之间周期性地调用某个进程，延迟时间很短。

当我看文档循环：

的循环允许用于处理消息的次数，可能在每次迭代的不同方式。主要在测试期间有用。

所以这对我没有用，因为我需要做一个无限循环（没有明确指定CamelLoopSize）。

我的第二个想法是用怎样的一个“递归”的：

from("direct:updateLoop").routeId("updateLoop") 
    .process(someProcess) 
    ... 
    .filter(someFilter) // Can be used to stop the workflow 
    .delay(18000000) // Wait 5 hours and start again 
    .to("direct:updateLoop") 

这非常适用于几天后，但大约600次迭代，这将失败，并StackOverflowException

有没有更好的办法在无限循环中运行我的进程？

Answer 1

使用Camel Timer组件：

from("timer://foo?fixedRate=false&period=18000000") 
    .process(someProcess); 

如果fixedRate是假的，那么会发生没有重叠，看到Apache Camel timer: "period" vs "fixedRate"

Answer 2

递归可以使用骆驼的seda组件。

from("seda:updateLoop").routeId("updateLoop") 
    .process(someProcess) 
    ... 
    .filter(someFilter) // Can be used to stop the workflow 
    .delay(18000000) // Wait 5 hours and start again 
    .to("seda:updateLoop");