Discussion :

[the_frogkiller]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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();
	 } 
         }
     }
   }

[tchize_]

il faut faire appel à scheduler.scheduleJob(trigger) pour scheduler un Job. La classe Trigger n'est qu'un bean, elle n'est pas "active" en ce sens que tu peux y tripatouiller ceque tu veux, si tu dis pas a quartz de recalculer le scheduling, il le fera pas

[the_frogkiller]

il faut faire appel à scheduler.scheduleJob(trigger) pour scheduler un Job. La classe Trigger n'est qu'un bean, elle n'est pas "active" en ce sens que tu peux y tripatouiller ceque tu veux, si tu dis pas a quartz de recalculer le scheduling, il le fera pas

merci pour la réponse. j'ai pus résoudre mon problème. voilà le bout de code pour celui qui aura le même problème dans le cas d'erreur à traiter :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
Calendar cal = Calendar.getInstance();
Date current = new Date();
cal.setTime(current);
cal.add(Calendar.MINUTE, 2);
 
JobDetail jobDetail = arg0.getJobDetail();	
String groupe;
String name;
	if(arg0.getTrigger() instanceof CronTrigger){
		CronTrigger cronTrigger = (CronTrigger)arg0.getTrigger();
		System.out.println(DateUtils.getDateUtils().getDateFormatHeureMinuteSeconde(current) + " : " + cronTrigger.getCronExpression());
		groupe = cronTrigger.getGroup();
		name = cronTrigger.getName();
		}
	else {
		System.out.println(DateUtils.getDateUtils().getDateFormatHeureMinuteSeconde(current));
		groupe = arg0.getTrigger().getGroup();
		name = arg0.getTrigger().getName();
		}
 
	SimpleTrigger simpleTrigger = new SimpleTrigger("TriggerBoinc", Scheduler.DEFAULT_GROUP, cal.getTime());
	simpleTrigger.setRepeatCount(0);
 
	Scheduler scheduler = arg0.getScheduler();
	scheduler.unscheduleJob(name, groupe);
	scheduler.scheduleJob(jobDetail, simpleTrigger) ;

Si le traitement passe il suffit donc de remettre un CronTrigger.