Spring + Quartz重新分配或更新触发器?


问题内容

我正在使用Spring 3.2Quartz 2.2

target Classmethod

public class Producer {

    public void executeListener() {
        System.out.println(" Test Method . ");
    }
}

在我的春天applicationContext.xml

<bean id="producer" class="com.service.Producer" />

<bean id="jobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
  <property name="targetObject" ref="producer" />
  <property name="targetMethod" value="executeListener" />
  <property name="concurrent" value="false" />
</bean>

<bean id="simpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">
    <property name="jobDetail" ref="jobDetail" />
    <!-- 10 seconds -->
    <property name="startDelay" value="10000" />
    <!-- repeat every 5 seconds -->
    <property name="repeatInterval" value="5000" />
</bean>


<bean id="mySheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    <property name="triggers">
    <list>
        <!-- <ref bean="cronTrigger" /> -->
        <ref bean="simpleTrigger" />
    </list>
    </property>
</bean>

上面的代码正常工作,并且executeListener()nethod以的间隔连续执行,5 seconds并且启动延迟为10 sec

我尝试spring controller将触发器更新为,

@Controller
public class SpringController {

    @Autowired
    org.springframework.scheduling.quartz.SchedulerFactoryBean myScheduler;

    @Autowired
    org.springframework.scheduling.quartz.SimpleTriggerFactoryBean oldTrigger;

    @RequestMapping(value="/reSheduleTrigger.html",method=RequestMethod.POST)
    public @ResponseBody String reSheduleTrigger(@RequestParam(value="triggerInSec") String triggerInSec ){

        System.out.println("----------------- Changing the repeat interval request -----------");

        // obtain a builder that would produce the trigger
        TriggerBuilder<SimpleTrigger> tb = oldTrigger.getObject().getTriggerBuilder();

        Trigger newTrigger = tb.withSchedule(simpleSchedule().withIntervalInSeconds(triggerInSec).build());

        myScheduler.getObject().rescheduleJob(oldTrigger.getObject().getKey(),newTrigger  );

        return "success";
    }
}

但是我遇到了编译时错误Trigger newTrigger = tb.withSchedule(simpleSchedule().withIntervalInSeconds(triggerInSec).build());

我的需要:

我想让reshedule工作动态地执行executeListener()带有2 sec间隔的方法。

谢谢。


问题答案:

请尝试以下方法之一:

Trigger newTrigger = tb.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2)).build();

要么

Trigger newTrigger = tb.withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(2)).build();

两者在语法上都是有效的。您的问题似乎Trigger newTrigger = tb.withSchedule(simpleSchedule().withIntervalInSeconds(triggerInSec).build());是由不正确的包围引起的。即build()后面不应包含多余的括号,因为它会返回触发器。