Discussion :

[doons]

Bonjour,

J'ai un Job dans lequel je dois aller rechercher des données en base et ensuite les traiter.
Le problème est que l'EJB service que j'ai déclaré est toujours null.
J'ai vu toutes sortes de choses sur le net mais du coup je sais pas bien trop quoi faire pour faire fonctionner tout ça

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
 
public class DerniereSaisieJob implements Job {
 
	@EJB
	private HeureService m_heureService;
 
	@Override
	public void execute(JobExecutionContext arg0) throws JobExecutionException {
		System.out.println("Executing Job");
 
		try {
			LocalDate aujourdhui = new LocalDate();
			aujourdhui = aujourdhui.minusDays(5);
 
			List<VwHeureEmploye> lst = m_heureService.getVwHeureEmployeList();
			if (CollectionUtils.isNotEmpty(lst)) {
				List<String> lstExclusion = getLstExclusionAsEmailAdresses();
 
                        ......
                } catch (Exception e) {
			System.out.println(e);
			FacesContext.getCurrentInstance().addMessage(null, new FacesMessage(e.getMessage()));
		}
       }
}

Qqun peut-il m'aider à trouver une solution ?
Merci pour votre aide

[doons]

Voici une solution qui fonctionne :

Définir un WebListener

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
 
@WebListener
public class JobListener extends QuartzInitializerListener {
 
	@Override
	public void contextInitialized(ServletContextEvent sce) {
		super.contextInitialized(sce);
        ServletContext ctx = sce.getServletContext();
        StdSchedulerFactory factory = (StdSchedulerFactory) ctx.getAttribute(QUARTZ_FACTORY_KEY);
        try {
            Scheduler scheduler = factory.getScheduler();
 
            // Job de contrôle de la saisie des heures (Tous les jeudis à 5h30)
            JobDetail jobDetailControleSaisie = JobBuilder.newJob(DerniereSaisieJob.class).build();
            Trigger triggerControleSaisie = TriggerBuilder.newTrigger().withIdentity("controleSaisieHeures").withSchedule(
                    CronScheduleBuilder.cronSchedule("0 30 5 ? * THU")).startNow().build();
            scheduler.scheduleJob(jobDetailControleSaisie, triggerControleSaisie);
 
            scheduler.start();
        } catch (Exception e) {
            System.out.println("There was an error scheduling the jobs.");
        	ctx.log("There was an error scheduling the jobs.", e);
        }
	}
}

Et dans le job :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
 
public class DerniereSaisieJob extends EJB3InvokerJob implements Job {
 
	@Override
	public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
		JobDataMap dataMap = jobExecutionContext.getMergedJobDataMap();
	    dataMap.put(EJB_JNDI_NAME_KEY, "java:app/JobService");
	    dataMap.put(EJB_METHOD_KEY, "doControlerDerniereSaisie");
 
	    super.execute(jobExecutionContext);
	}
}

Et le service :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
 
@Stateless
@EJB(name = "java:app/JobService", beanInterface = JobService.class)
public class JobServiceImpl implements JobService {
 
	@EJB
	private EmployeDao m_employeDao;
 
	@Override
	public void doControlerDerniereSaisie() throws MessagingException {
		...
        }
}

D'un coup que ça puisse servir à qqun

[OButterlin]

Le problème vient du fait que ta classe n'est pas prise en compte par un système d'injection, du coup, les annotations @EJB ne sont pas traitées.
La solution simple consiste à faire un lookup jndi pour récupérer l'ejb.

Code :

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

1
2
3
 
ctx = new InitialContext();
ctx.lookup("le nom de la facade de l'ejb");  <- ça dépend du serveur utilisé, mais généralement, au démarrage du serveur, il les liste

[doons]

Merci pour ta réponse.

Du coup c'est mieux de faire par lookup jndi ou comme j'ai fais ?

[tchize_]

Ben, c'est déjà comme ça que tu fais, l'ejb invoker job fait un lookup et appelle une méthode sur l'EJB

[doons]

Ok, du coup c'est quand même plus propre d'utiliser l' ejb invoker, non ?

[tchize_]

dans l'invoker la méthode est appelée par reflection. Donc pas top quand tu fera du refactoring et la changeant de nom. De plus, tu ne peux pas lui passer facilement des paramètres. En faisant le lookup toi même tu peux caster vers l'interface et appeler toutes les méthodes que tu veux.

[doons]

Très bien, merci

Du coup j'ai gardé mon listener :

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
27
28
29
30
31
 
@WebListener
public class JobListener extends QuartzInitializerListener {
 
	@Override
	public void contextInitialized(ServletContextEvent sce) {
		super.contextInitialized(sce);
               ServletContext ctx = sce.getServletContext();
               StdSchedulerFactory factory = (StdSchedulerFactory) ctx.getAttribute(QUARTZ_FACTORY_KEY);
          try {
            Scheduler scheduler = factory.getScheduler();
 
            // Job de contrôle de la saisie des heures (Tous les jeudis à 5h30)
            JobDetail jobDetailControleSaisie = JobBuilder.newJob(DerniereSaisieJob.class).build();
            Trigger triggerControleSaisie = TriggerBuilder.newTrigger().withIdentity("controleSaisieHeures").withSchedule(
            		CronScheduleBuilder.cronSchedule("0 30 5 ? * THU")).startNow().build();
            scheduler.scheduleJob(jobDetailControleSaisie, triggerControleSaisie);
 
            // Job de rappel de saisie des absences planifiées (Le 10 mars, juin, septembre, décembre à 07h15)
            JobDetail jobDetailRappelSaisieAbsences = JobBuilder.newJob(RappelSaisieAbsencesJob.class).build(); 
            Trigger triggerRappelSaisieAbsences = TriggerBuilder.newTrigger().withIdentity("rappelSaisieAbsencesPlanifiees").withSchedule(
            		CronScheduleBuilder.cronSchedule("0 15 7 10W 3,6,9,12 *")).startNow().build();
            scheduler.scheduleJob(jobDetailRappelSaisieAbsences, triggerRappelSaisieAbsences);
 
            scheduler.start();
        } catch (Exception e) {
            System.out.println("There was an error scheduling the jobs.");
        	ctx.log("There was an error scheduling the jobs.", e);
        }
	}
}

Et fais directement dans mon 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
16
17
18
19
20
21
public class RappelSaisieAbsencesJob implements Job {

	@Override
	public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
		try {
			
			InitialContext ctx = new InitialContext();
			EmployeService employeService = (EmployeService) ctx.lookup("java:global/erp/EmployeServiceImpl");
			
			List<Employe> lst = employeService.getEmployeList(true);
			if (CollectionUtils.isNotEmpty(lst)) {
				for (Employe employe : lst) {
					EmailingUtils.sendEmail(listEmail, "ERP-Rappel saisie des absences planifiées", contenu, false);
				}
			}
		} catch (MessagingException | NamingException e) {
			e.printStackTrace();
		}
	}
}

Par contre j'ai toujours un souci sur comment gérer au mieux les erreurs, typiquement la Messaging et Naming Exception. Vous faites comment pour les gérer ?

Merci

[OButterlin]

Il faut passer par JobExecutionException, c'est le moyen pour indiquer au scheduler que le job s'est terminé en erreur.