toD() - 通过 Quartz 调度的骆驼 2.23 中的动态 URI 形成

Question

我是 Apache camel 的新手，想实现 toD()，它可以动态构建 URI 并从 Beans 添加请求参数值。

下面的代码sn-p -

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}") .process(处理器)

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

正在调用处理器，计算和设置我从端点响应中获得的 Bean 值。但是下一次 Quartz 打 url 的时候，bean 的值没有更新，取默认值 . bean定义是常用的getter setter，注册是我用过的Simple registry

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

            simpleRegistry.put("bean", bean);

提前致谢

Answer 1

为了在 camel-route 上使用 动态 URI，您必须在 Simple变量 /strong> 表达式。

由于 Camel 2.16.0 发布端点实现toD() 支持Simple expression language，因此您可以定义dynamic-URI as message-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 字符串中使用Bean language 直接插值。这个 bean-component bean: 告诉 Camel 获取使用您指定名称 bean 注册的 bean 并调用指定的方法 from 和 size。

Apache Camel: Rest DSL，Using Dynamic to()部分也有注释：

注意：我们需要使用.endRest() 告诉Camel 路由的终点，这样我们才能回到Rest DSL 继续定义REST 服务。

否则，您可以在常规 to() 中使用 simple 来实现该动态端点。见Apache Camel: How to use a dynamic URI in to()。