Параметризация планировщика EJB с помощью выражения расписания
Я использую EJB 3.1 и jboss-eap-6.4, и я хочу установить некоторые динамические параметры для часов, минут и секунд планировщика ejb следующим образом:
Непараметрический код - который запускается через 30 секунд каждые 5 минут:
@Singleton
@Startup
public class TriggerJob {
@EJB
//some db injections
@PostConstruct
public void onStartup() {
try {
preparation();
} catch (CertificateVerificationException e) {
e.printStackTrace();
}
}
@Schedule(second = "30", minute = "*/5", hour = "*", persistent = false)
public void preparation() {
//my scheduled tasks
}
}
Приведенный выше код выполняется правильно.
Динамический параметрический код - который должен запускаться через 30 секунд каждые 5 минут:
@Singleton
@Startup
public class TriggerJob {
@EJB
//some injections
private boolean runningFlag = false;
@Resource
private TimerService timerService;
public void setTimerService(TimerService timerService) {
this.timerService = timerService;
}
@Timeout
public void timerTimeout() {
try {
preparation();
} catch (CertificateVerificationException e) {
e.printStackTrace();
}
}
@PostConstruct
private void postCunstruct() {
timerService.createCalendarTimer(createSchedule(),new TimerConfig("EJB timer service timeout at ",false));
}
private ScheduleExpression createSchedule() {
ScheduleExpression expression = new ScheduleExpression();
expression.hour("*")
.minute("*/5")
.second("30");
return expression;
}
public void preparation(){
// my scheduled tasks
}
}
Приведенный выше код не выполняется правильно, обычно он выполняется несколько раз в секунду.
Кроме того, я прочитал некоторые другие вопросы, которые не помогли мне:
Динамические параметры для метода @Schedule в EJB 3.x
Использование службы таймера - Учебник по Java EE 6
Любая помощь будет оценена.
1 ответ
Решение
Вместо этого используйте программное планирование, вот пример:
@Singleton
@Startup
public class TriggerJob{
@EJB
//some injections
@Resource
private TimerService timerService;
@PostConstruct
public void init() {
createTimer();
//the following code resolve my startup problem
try {
preparation();
} catch (CertificateVerificationException e) {
e.printStackTrace();
}
}
@Timeout
public void timerTimeout() {
try {
preparation();
} catch (CertificateVerificationException e) {
e.printStackTrace();
}
}
private void createTimer() {
ScheduleExpression scheduleExpression = new ScheduleExpression();
scheduleExpression.second("30").minute("*/5").hour("*");
TimerConfig timerConfig = new TimerConfig();
timerConfig.setPersistent(false);
timerService.createCalendarTimer(scheduleExpression, timerConfig);
}
public void preparation(){
// my scheduled tasks
}
}