主页
产品
Red Hat Integration
2022.Q4
Camel Spring Boot 参考 3.14
39.12. 使用 QuartzScheduledPollConsumerScheduler

39.12. 使用 QuartzScheduledPollConsumerScheduler

Quartz 组件提供了一个 Polling Consumer 调度程序，它允许对 Polling Consumer （如文件和 FTP 用户）使用基于 cron 的调度。

例如，要使用基于 cron 的表达式每秒轮询一次文件，可将 Camel 路由定义为：

    from("file:inbox?scheduler=quartz&scheduler.cron=0/2+*+*+*+*+?")
       .to("bean:process");

    from("file:inbox?scheduler=quartz&scheduler.cron=0/2+*+*+*+*+?")
       .to("bean:process");

Copy to Clipboard

Toggle word wrap

请注意，我们定义 scheduler=quartz 以指示 Camel 使用基于 Quartz 的调度程序。然后，我们使用 scheduler.xxx 选项来配置调度程序。Quartz 调度程序需要设置 cron 选项。

支持以下选项：

Expand

参数	默认	类型	描述
`quartzScheduler`	`null`	`org.quartz.Scheduler`	使用自定义 Quartz 调度程序。如果没有配置，则使用来自组件的共享调度程序。
`cron`	`null`	`字符串`	Mandatory ：定义用于触发轮询的 cron 表达式。
`triggerId`	`null`	`字符串`	指定触发器 id。如果未提供，则生成和使用 UUID。
`triggerGroup`	`QuartzScheduledPollConsumerScheduler`	`字符串`	指定触发器组。
`timeZone`	`默认`	`TimeZone`	用于 CRON 触发器的时区。

重要

记住从端点 URI 配置这些选项必须使用 调度程序 作为前缀。

例如，配置 trigger id 和 group ：

    from("file:inbox?scheduler=quartz&scheduler.cron=0/2+*+*+*+*+?&scheduler.triggerId=myId&scheduler.triggerGroup=myGroup")
       .to("bean:process");

    from("file:inbox?scheduler=quartz&scheduler.cron=0/2+*+*+*+*+?&scheduler.triggerId=myId&scheduler.triggerGroup=myGroup")
       .to("bean:process");

Copy to Clipboard

Toggle word wrap

Spring 中还有一个 CRON 调度程序，因此您也可以使用以下内容：

    from("file:inbox?scheduler=spring&scheduler.cron=0/2+*+*+*+*+?")
       .to("bean:process");

    from("file:inbox?scheduler=spring&scheduler.cron=0/2+*+*+*+*+?")
       .to("bean:process");

Copy to Clipboard

Toggle word wrap

返回顶部

39.12. 使用 QuartzScheduledPollConsumerScheduler

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links