Apache Camel quartz2不应用更改的cron表达式

Question

我试图在集群模式下使用camel-quartz2组件和jdbcjobstore。

quartz.properties文件：

org.quartz.scheduler.instanceId=AUTO
org.quartz.scheduler.instanceName=JobCluster

org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.oracle.OracleDelegate
org.quartz.jobStore.dataSource=dsQuartzTest

org.quartz.jobStore.isClustered=true

org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount=5
org.quartz.dataSource.dsQuartzTest.driver = oracle.jdbc.driver.OracleDriver
org.quartz.dataSource.dsQuartzTest.URL = jdbc:oracle:thin:pmuser@//10.13.13.10:1521/PDB1
org.quartz.dataSource.dsQuartzTest.user = pmuser
org.quartz.dataSource.dsQuartzTest.password = oracle
org.quartz.dataSource.dsQuartzTest.maxConnections = 10

<?xml version="1.0" encoding="UTF-8"?>
<!-- Configures the Camel Context-->

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:camel="http://camel.apache.org/schema/spring"
       xsi:schemaLocation="
       http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://camel.apache.org/schema/spring
       http://camel.apache.org/schema/spring/camel-spring.xsd">

    <bean id="quartz2" class="org.apache.camel.component.quartz2.QuartzComponent">
        <property name="propertiesFile" value="quartz.properties"/>
    </bean>

    <bean id="quartzBean" class="com.ubs.rbs.integration.QuartzBean"/>

    <camel:camelContext xmlns="http://camel.apache.org/schema/spring">

        <camel:route id="quartzRoute">
            <camel:from uri="quartz2://tictac?cron=0+0/5+*+1/1+*+?+*"/>
            <camel:setBody>
                <camel:simple>
                    ${header.triggerName} - ${header.fireTime}
                </camel:simple>
            </camel:setBody>
            <camel:to uri="log:hello"/>
        </camel:route>

<!--
        <camel:route>
            <camel:from uri="timer://updateQuartzRoute?repeatCount=1"/>
            <camel:to uri="bean:quartzBean?method=reschedule(*,'quartzRoute')"/>
        </camel:route>
-->

    </camel:camelContext>

</beans>

public class QuartzBean {

    public void reschedule(CamelContext context, String quartzRouteId) throws Exception {
        QuartzEndpoint endpoint = (QuartzEndpoint) context.getRoute(quartzRouteId).getEndpoint();
        QuartzComponent component = endpoint.getComponent();
        Scheduler scheduler = component.getScheduler();

        Trigger oldTrigger = scheduler.getTrigger(endpoint.getTriggerKey());
        TriggerBuilder tb = oldTrigger.getTriggerBuilder();

        Trigger newTrigger = tb.withSchedule(CronScheduleBuilder.cronSchedule(endpoint.getCron())).build();

        scheduler.rescheduleJob(oldTrigger.getKey(), newTrigger);
    }
}

或者，我可以为camel-quartz2组件打补丁，如下所示(org.apache.camel.component.quartz2.quartzendpoint#AddJobInScheduler):

private void addJobInScheduler() throws Exception {
    // Add or use existing trigger to/from scheduler
    Scheduler scheduler = getComponent().getScheduler();
    JobDetail jobDetail;
    boolean triggerExisted = scheduler.getTrigger(triggerKey) != null;
    if (triggerExisted) {
        ensureNoDupTriggerKey();
    }

    jobDetail = createJobDetail();
    Trigger trigger = createTrigger(jobDetail);

    updateJobDataMap(jobDetail);

    // Schedule it now. Remember that scheduler might not be started it, but we can schedule now.
    Date nextFireDate = triggerExisted ? scheduler.rescheduleJob(triggerKey, trigger) : scheduler.scheduleJob(jobDetail, trigger);
    if (LOG.isInfoEnabled()) {
        LOG.info("Job {} (triggerType={}, jobClass={}) is scheduled. Next fire date is {}",
                 new Object[] {trigger.getKey(), trigger.getClass().getSimpleName(),
                               jobDetail.getJobClass().getSimpleName(), nextFireDate});
    }

    // Increase camel job count for this endpoint
    AtomicInteger number = (AtomicInteger) scheduler.getContext().get(QuartzConstants.QUARTZ_CAMEL_JOBS_COUNT);
    if (number != null) {
        number.incrementAndGet();
    }

    jobAdded.set(true);
}

与项目存储库中的当前版本不同，我的版本总是创建新的触发器，如果触发器已经存在，则重新安排作业。

我的问题是：我是否遗漏了一些明显的东西？在这种情况下，该组件应该如何工作？我应该尝试改变组件本身，还是有更好的方法从外部改变它的时间表？

UPD：我尝试了maven的2.13.1版本和Snapshot的2.14版本。

Answer 1

Camel 2.12.2和之前的版本已经知道与石英有关的bug。如果你不是，请尝试2.12.3或更高的版本。