我有一个由cron表达式触发的spring集成流程,如下所示:
<int-ftp:inbound-channel-adapter id="my-input-endpoint" ...>
<int:poller trigger="my-trigger"/>
</int-ftp:inbound-channel-adapter>
<bean id="my-trigger"
class="org.springframework.scheduling.support.CronTrigger">
<constructor-arg value="0 * * * * *" />
</bean>
Run Code Online (Sandbox Code Playgroud)
它工作正常.但是现在我必须扩展实现以使其集群就绪(在同一时间点仅在一个集群节点上执行作业).
我希望在集群模式下使用Quartz框架(在数据库中保持作业状态)来触发此集成流程.Quartz提供了一个开箱即用的漂亮解决方案.唯一的问题是如何将Quartz与现有的inbout-channer-adapter集成?"poller"的"trigger"属性只接受org.springframework.scheduling.Trigger的子类.我找不到"poller trigger"和Quartz框架之间的任何桥梁.
提前谢谢了!