如何创建自定义的阿帕奇骆驼计时器对象

Question

有没有一种方法可以创建一个定制的ApacheCamel定时器作为java代码中定义的对象，而不是在endpointURI中将其定义为dsl字符串模式？

在文档中：https://camel.apache.org/components/latest/timer-component.html这里提到了这个定时器URI查询参数：

但我还没有找到创建“高级”自定义计时器的示例。

而不是像这样指定计时器：

from("timer://foo?fixedRate=true&period=60000").to("bean:myBean?method=someMethodName");

我想将其指定为：

from("timer://foo?timer=com.MyCustomTimer").to("bean:myBean?method=someMethodName");

这将伴随着:

class MyCustomTimer implements TimerInterfaceICantFind{

    public MyCustomTimer(){
        setFixedRate(true);
        setPeriod(60000);   
    }
}

我想这样做，这样我就可以通过java setter动态指定计时器属性，而不是将它们替换为正在构造的字符串URI。

在撰写本文时，其他人已经询问了计时器URI字符串语法，但没有询问自定义计时器。例如:

Apache 骆驼计时器路由 URI 语法

我在camel源代码中看到，好像TimerComponent.getTimer()正在返回一个java.util.Timer

这是否意味着需要创建核心 java 类：java.util.Timer - 并在其上设置属性，而不是将计时器对象的驼峰版本用于自定义计时器？

Answer 1

如果您坚持动态生成计时器，也许您可以看看Camel EndpointDSL，它允许您动态构建endpoint。这里是定时器和使用它的示例。

Answer 2

camel文档中引用的自定义定时器不是camel对象，而是java.util.Timer对象。在骆驼路线上手动操作是较低级的，并且对用户不友好。不建议使用。

如果不手动指定终结点字符串 uri，则无法实例化骆驼 TimerEndpoint 对象并对其值使用 setter。

如果未提供该 uri - 骆驼将引发异常并显示以下消息：

未指定endpointUri，并且org . Apache . camel . component . timer . timer endpoint未实现createEndpointUri()来创建默认值。

如果使用 camel 3，则有一个endpoint dsl 选项可用，即endpoint路由构建器，该选项可以通过生成器创建计时器endpoint：

RouteBuilder.addRoutes(camelContext, rb ->
    rb.from(timer("myTimer").fixedRate(true).period(500).advanced().synchronous(false))
            .delay(simple("${random(250,1000)}"))
            .process(this::newOrder)
            .to(direct("cafe")));

https://github.com/apache/camel-examples/blob/master/examples/camel-example-cafe-endpointdsl/src/main/java/org/apache/camel/example/cafe/CafeRouteBuilder.java#L69