主页
产品
Red Hat build of Apache Camel
4.0
Red Hat build of Apache Camel for Spring Boot Reference
98.13. 使用 QuartzScheduledPollConsumerScheduler

98.13. 使用 QuartzScheduledPollConsumerScheduler

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

例如，要使用基于 cron 的表达式每第 2 秒轮询一次文件，可将 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`	`字符串`	必需：定义用于触发轮询的 cron 表达式。
`triggerId`	`null`	`字符串`	指定触发器 ID。如果没有提供，则生成和使用 UUID。
`triggerGroup`	`QuartzScheduledPollConsumerScheduler`	`字符串`	指定触发器组。
`timeZone`	`默认值`	`TimeZone`	用于 CRON 触发器的时区。

重要

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

例如，配置触发器 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

返回顶部

98.13. 使用 QuartzScheduledPollConsumerScheduler

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links