toD（）-通过Quartz调度的camel 2.23中的动态URI形成

Question

来自（“quartz2:/timer？cron=0+0/1+++*+？”）.noAutoStartup().routeId(ROUTE_ID).log（“route started”）.tod（http：//localhost:3420/contextPath？from=${bean:bean.from}“+”&size=${bean:bean.size}“）.process（处理器）

似乎是，每次通过Quartz点击都触发了相同的URL，因此我看到重复的值保存到DB中。请说明为什么动态uri没有按预期工作。

我正在调用处理器，计算并设置从endpoint响应中得到的Bean值。但当Quartz下一次点击url时,bean值不会更新,而是取默认值。Bean定义通常是getter setter，注册是我用过的简单注册表

SimpleRegistry simpleRegistry = new SimpleRegistry ();
            // create CamelContext
            context = new DefaultCamelContext (simpleRegistry);

            simpleRegistry.put("bean", bean);

提前致谢

Answer 1

为了在骆驼路由上使用动态URI，必须在一个简单表达式中包含变量。

由于Camel 2.16.0版本endpoint实现tod()支持简单表达式语言，因此您可以将动态URI定义为消息endpoint：

from("quartz2://timer?cron=0+0/1+++*+?")
    .noAutoStartup()
    .routeId(ROUTE_ID)
    .log("Route Started")
    .toD( "http://localhost:3420/contextpath?from=${bean:bean.from}&size=${bean:bean.size}" );

因此，表达式${Bean:Bean.from}和${Bean:Bean.size}应该通过在URI-String中使用Bean语言直接插值。这个bean-componentbean:告诉Camel用您指定的名称bean注册bean，并调用指定的方法from和size。

Apache Camel：Rest DSL,Using Dynamic to（）一节也有一个说明：

注意：我们需要使用.endrest()来告诉Camel路由的终点，这样我们就可以回到Rest DSL并继续定义Rest服务。

否则，您可以在常规to()中使用simple来实现动态endpoint。请参见Apache Camel：如何在to（）中使用动态URI。