38.12. Using QuartzScheduledPollConsumerScheduler
Quartz 组件提供了一个 Polling Consumer 调度程序,它允许将基于 cron 的调度用于轮询消费者(如文件和 FTP 用户)。
例如,要使用基于 cron 的表达式轮询每第二文件,那么 Camel 路由可以定义为:
from("file:inbox?scheduler=quartz&scheduler.cron=0/2+*+*+*+*+?") .to("bean:process");
请注意,我们定义了 scheduler=quartz
以指示 Camel 使用基于 Quartz 的调度程序。然后,我们使用 scheduler.xxx
选项配置调度程序。Quartz 调度程序要求设置 cron 选项。
支持以下选项:
参数 | 默认 | 类型 | 描述 |
---|---|---|---|
|
|
| 使用自定义 Quartz 调度程序。如果没有配置,则使用组件中的共享调度程序。 |
|
|
| 强制 :定义要触发轮询的 cron 表达式。 |
|
|
| 指定触发器 id。如果没有提供 UUID,则生成和使用 UUID。 |
|
|
| 指定触发器组。 |
|
|
| 用于 CRON 触发器的时区。 |
请记住,从端点 URI 配置这些选项必须带有 调度程序
前缀。
例如,配置触发器 id 和组:
from("file:inbox?scheduler=quartz&scheduler.cron=0/2+*+*+*+*+?&scheduler.triggerId=myId&scheduler.triggerGroup=myGroup") .to("bean:process");
Spring 中有一个 CRON 调度程序,因此也可以使用:
from("file:inbox?scheduler=spring&scheduler.cron=0/2+*+*+*+*+?") .to("bean:process");