API qartz et mise à jour du cronTrigger
bonjour,
Voilà je suis en train de développer une application dont le but est d'aller chercher sur un site un fichier xml, le parser et enregistrer les informations en base de donnée. Cette tache doit être éffectuée quotidienement à heure fixe.
En fonction des erreurs d'excécutions je doit pouvoir relancer ou non le Job à une heure donnée. par exemple lors d'un problème de connexion internet je voudrait relancer le job 1h plus tard, si le job se termine normalement on reprend l'éxcécution programmée habituelle.
mon job est un StatefulJob ce qui me permet de récupérer des informations dans le jobDataMap au niveau du listener.
Le problèmes est que visiblement le trigger est soit à nouveau instancié lors du lancement du job ou que celui qui se trouve dans le JobExecutionContext arg0 du listener est un clone. donc changer ses paramètres ne change rien.
ma question est donc: Comment peut on faire pour modifier les paramètres du cronTrigger de manière dynamique?
main de l'application
Code:
1
2
3
4
5
6
7
8
9
| SchedulerFactory schedFactSchedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedFactSchedulerFactory.getScheduler();
scheduler.addJobListener(new BoincJobListener());
scheduler.start();
JobDetail jobDetail = new JobDetail("BoincJob", Scheduler.DEFAULT_GROUP, BoincJob.class);
jobDetail.addJobListener("BoincJobListener");
CronTrigger simpleTrigger = new CronTrigger("cronTriggerBoinc", "BoincGroup", Constantes.DEFAULT_CRON);
scheduler.scheduleJob(jobDetail, simpleTrigger) ; |
listener du job
Code:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
| @Override
public void jobWasExecuted(JobExecutionContext arg0, JobExecutionException arg1) {
if(arg1 != null){
if(arg1.getCause() instanceof ParsingException){
ParsingException pe = (ParsingException) arg1.getCause();
try {
CronTrigger cronTrigger = (CronTrigger)arg0.getTrigger();
cronTrigger.setCronExpression(new CronExpression("0 0/30 * * * ?"));
}
catch (ParseException e) {
e.printStackTrace();
}
}
}
} |
