Scheduler and joblistener

[hadjila hadjilak]

Hi,
I have always a same problem:

I would to integrate m y class UnJobListener ,who impelement joblistener, in my quartz (file xml )

This is my file

<?xml version="1.0" encoding="UTF-8"?> <!-- ==================================================================== SVN-Author : $LastChangedBy: cdue $ SVN-Date : $LastChangedDate: 2013-02-22 19:12:35 +0100 (Fri, 22 Feb 2013) $ SVN-Revision : $LastChangedRevision: 1201 $ SVN-Header : $HeadURL: https://svn.prosodie/NCA/trunk/NCAScheduler/src/schedulerAppContext.xml $ SVN-Id : $Id: schedulerAppContext.xml 1388 2013-03-27 08:12:22Z cdue $ ==================================================================== --> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd"> <!-- Import NCA Batch applicationContext: mandatory to be able to run jobs usin jobLauncher. --> <import resource="applicationContext.xml" /> <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="${DBConnectionFactory.default.driver}" /> <property name="url" value="${DBConnectionFactory.default.url}" /> <property name="username" value="${DBConnectionFactory.default.user}" /> <property name="password" value="${DBConnectionFactory.default.password}" /> </bean> <bean id="jobRepository" class="org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean"> <property name="transactionManager" ref="transactionManager" /> </bean> <bean id="transactionManager" class="org.springframework.batch.support.transaction.ResourcelessTransactionManager"> </bean> <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="locations"> <list> <value>file:${app.home}/cfg/nca.properties</value> <value>file:${app.home}/cfg/${module.name}/${module.name}.properties </value> </list> </property> </bean> <bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"> <property name="dataSource" ref="dataSource" /> <property name="jpaVendorAdapter"> <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"> <property name="showSql" value="${hibernate.show_sql}" /> </bean> </property> <property name="jpaPropertyMap"> <map> <entry key="hibernate.cache.use_second_level_cache" value="${hibernate.cache.use_second_level_cache}" /> <entry key="hibernate.cache.use_query_cache" value="${hibernate.cache.use_query_cache}" /> <entry key="hibernate.cache.provider_class" value="${hibernate.cache.provider_class}" /> <entry key="hibernate.dialect" value="${hibernate.dialect}" /> <entry key="hibernate.show_sql" value="${hibernate.show_sql}" /> <entry key="hibernate.connection.show_sql" value="true" /> <entry key="hibernate.id.new_generator_mappings" value="false" /> </map> </property> </bean> <bean id="jobRegistry" class="org.springframework.batch.core.configuration.support.MapJobRegistry" /> <bean id="taskExecutor" class="org.springframework.core.task.SimpleAsyncTaskExecutor" /> <!-- Or ThreadPoolTaskExecutor... --> <bean id="jobLauncher" class="com.prosodie.nca.batch.launch.JpaIteratorJobLauncher"> <property name="jobRepository" ref="jobRepository" /> <property name="entityManagerFactory" ref="entityManagerFactory" /> <property name="taskExecutor" ref="taskExecutor" /> </bean> <bean class="org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor"> <property name="jobRegistry" ref="jobRegistry" /> </bean> <bean id="mapJobRepository" class="org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean" lazy-init="true" autowire-candidate="false" /> <!-- ***************************************************** --> <!-- Notilus project codes export jobDetail definition. --> <!-- ***************************************************** --> <bean id="notilusProjectCodesExportJobDetail" class="org.springframework.scheduling.quartz.JobDetailFactoryBean"> <property name="jobClass" value="com.prosodie.nca.scheduler.JobLauncherDetails" /> <property name="group" value="quartz-batch" /> <!-- <property name="concurrentExectionDisallowed" value="true" /> --> <property name="jobDataAsMap"> <bean class="org.quartz.JobDataMap"> <constructor-arg> <map> <entry key="jobName" value="batch.export.notilus.project.codes" /> <!-- <entry key="input.jpa.queryString" value="select codeBanque from Emetteur" /> --> <entry key="maxRetry" value="3" /> <entry key="listenerDelay" value="2000" /> <!-- The alarmManagedByJob parameter set to false tells the job not to send ExploitAlarms on job failure. --> <entry key="alarmManagedByJob" value="false" /> </map> </constructor-arg> </bean> </property> </bean> <!-- ***************************************************** --> <!-- Notilus exemple project nca --> <!-- ***************************************************** --> <bean id="notilusProjectCodesExempleNca" class="org.springframework.scheduling.quartz.JobDetailFactoryBean"> <property name="jobClass" value="com.prosodie.nca.scheduler.JobLauncherDetailsExemple" /> <property name="group" value="quartz-batch" /> <!-- Concurrent <property name="concurrentExectionDisallowed" value="true" /> --> <property name="jobDataAsMap"> <bean class="org.quartz.JobDataMap"> <constructor-arg> <map> <entry key="jobName" value="batch.exemple.projet.nca" /> <!-- <entry key="input.jpa.queryString" value="select codeBanque from Emetteur" /> --> <entry key="maxRetry" value="3" /> <entry key="listenerDelay" value="2000" /> <!-- The alarmManagedByJob parameter set to false tells the job not to send ExploitAlarms on job failure. --> <entry key="alarmManagedByJob" value="false" /> </map> </constructor-arg> </bean> </property> </bean> <!-- *************************************************************** --> <!-- Declare a job listener that will take care of job retries, etc. --> <!-- *************************************************************** --> <!-- ***************************************************** --> <!-- Here is the Scheduler Factory that will trigger jobs. --> <!-- ***************************************************** --> <bean id="ncaSchedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="schedulerName" value="ncaScheduler" /> <property name="dataSource" ref="dataSource" /> <property name="waitForJobsToCompleteOnShutdown" value="true" /> <property name="overwriteExistingJobs" value="true"/> <!-- concurrence <property name="DisallowConcurrentExecution" value="true"> --> <property name="schedulerContextAsMap"> <map> <entry key="jobLocator" value-ref="jobRegistry" /> <entry key="jobLauncher" value-ref="jobLauncher" /> </map> </property> <property name="listener"> <bean id="ncaJobListener" class="com.prosodie.nca.scheduler.NcaJobListener"> <property name="name" value="nca_job_listener"/> </bean> </property> <property name="triggers"> <list> <!-- Add a trigger definition for Notilus project codes export job. --> <bean id="notilusProjectCodesExportCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"> <property name="jobDetail" ref="notilusProjectCodesExportJobDetail" /> <!-- <property name="cronExpression" value="0/50 * * * * ?" /> --> <property name="cronExpression" value="50 * * * * ?" /> <property name="group" value="quartz-batch" /> </bean> <!-- Add a trigger definition for Notilus project codes exemple job. --> <bean id="notilusProjectCodesExempleCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"> <property name="jobDetail" ref="notilusProjectCodesExempleNca" /> <property name="cronExpression" value="30 * * * * ?"/> <property name="group" value="quartz-batch" /> </bean> </list> </property> <!-- Make the Spring Context Available --> <!-- <property name="applicationContextSchedulerContextKey" value="schedulerApplicationContext" /> --> <property name="quartzProperties"> <props> <prop key="org.quartz.scheduler.skipUpdateCheck">${quartz.scheduler.skipUpdateCheck}</prop> <prop key="org.quartz.scheduler.instanceName">${quartz.scheduler.instanceName}</prop> <prop key="org.quartz.scheduler.instanceId">${quartz.scheduler.instanceId}</prop> <prop key="org.quartz.threadPool.class">${quartz.threadPool.class}</prop> <prop key="org.quartz.threadPool.threadCount">${quartz.threadPool.threadCount}</prop> <prop key="org.quartz.threadPool.threadPriority">${quartz.threadPool.threadPriority}</prop> <prop key="org.quartz.jobStore.misfireThreshold">${quartz.jobStore.misfireThreshold}</prop> <prop key="org.quartz.jobStore.class">${quartz.jobStore.class}</prop> <prop key="org.quartz.jobStore.driverDelegateClass">${quartz.jobStore.driverDelegateClass}</prop> <prop key="org.quartz.jobStore.useProperties">${quartz.jobStore.useProperties}</prop> <prop key="org.quartz.jobStore.dataSource">${quartz.jobStore.dataSource}</prop> <prop key="org.quartz.jobStore.tablePrefix">${quartz.jobStore.tablePrefix}</prop> <!-- <prop key="org.quartz.dataSource.myDS.driver">com.sybase.jdbc4.jdbc.SybDriver</prop> <prop key="org.quartz.dataSource.myDS.URL">jdbc:sybase:Tds:192.168.154.39:5001/NCA?Language=us_english&charset=iso_1</prop> <prop key="org.quartz.dataSource.myDS.user">sa</prop> <prop key="org.quartz.dataSource.myDS.password"></prop> <prop key="org.quartz.dataSource.myDS.maxConnections">5</prop> <prop key="org.quartz.dataSource.myDS.validationQuery">select 0 from dual</prop> --> </props> </property> </bean> </beans>


And there are the errors:

Exception in thread "main" org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'ncaSchedulerFactoryBean' defined in class path resource [schedulerAppContext.xml]: Cannot create inner bean 'ncaJobListener' of type [com.prosodie.nca.scheduler.NcaJobListener] while setting bean property 'listener'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'ncaJobListener' defined in class path resource [schedulerAppContext.xml]: Instantiation of bean failed; nested exception is org.springframework.beans.BeanInstantiationException: Could not instantiate bean class [com.prosodie.nca.scheduler.NcaJobListener]: No default constructor found; nested exception is java.lang.NoSuchMethodException: com.prosodie.nca.scheduler.NcaJobListener.<init>()
at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveInnerBean(BeanDefinitionValueResolver.java:281)
at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveValueIfNecessary(BeanDefinitionValueResolver.java:120)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyPropertyValues(AbstractAutowireCapableBeanFactory.java:1360)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1118)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:517)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456)
at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:294)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:225)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:291)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:193)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:567)
at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:913)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:464)
at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:139)
at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:83)
at com.prosodie.nca.scheduler.StandaloneScheduler.main(StandaloneScheduler.java:46)
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'ncaJobListener' defined in class path resource [schedulerAppContext.xml]: Instantiation of bean failed; nested exception is org.springframework.beans.BeanInstantiationException: Could not instantiate bean class [com.prosodie.nca.scheduler.NcaJobListener]: No default constructor found; nested exception is java.lang.NoSuchMethodException: com.prosodie.nca.scheduler.NcaJobListener.<init>()
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateBean(AbstractAutowireCapableBeanFactory.java:997)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:943)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:485)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456)
at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveInnerBean(BeanDefinitionValueResolver.java:270)
... 15 more
Caused by: org.springframework.beans.BeanInstantiationException: Could not instantiate bean class [com.prosodie.nca.scheduler.NcaJobListener]: No default constructor found; nested exception is java.lang.NoSuchMethodException: com.prosodie.nca.scheduler.NcaJobListener.<init>()
at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:72)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateBean(AbstractAutowireCapableBeanFactory.java:990)
... 19 more
Caused by: java.lang.NoSuchMethodException: com.prosodie.nca.scheduler.NcaJobListener.<init>()
at java.lang.Class.getConstructor0(Unknown Source)
at java.lang.Class.getDeclaredConstructor(Unknown Source)
at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:67)
... 20 more


Please, please some one to help me!!

[Jayesh A Lalwani]

The problem is here

<property name="listener">  
  
<bean id="ncaJobListener" class="com.prosodie.nca.scheduler.NcaJobListener">  
        <property name="name" value="nca_job_listener"/>  
 </bean>  
  
  
  
  
 </property> 

You need to look at the java docs of the NcaJobListener class. How are you suppossed to initialize it. Does it have a constructor?

[hadjila hadjilak]

Hi,
In the first thanks for your reply.
Fort the last mistakes yes the problem are in the constructor for my class and i have resolved this, then when you run my programme
dosen't use my class listener, i don't know how do you do for this:

This is my class jobluncher who lunche my scheduler:

import java.util.Date;
import java.util.Locale;
import java.util.Map;
import java.util.Map.Entry;

import org.quartz.DisallowConcurrentExecution;
import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobListener;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.batch.core.BatchStatus;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.JobParametersBuilder;
import org.springframework.batch.core.configuration.JobLocator;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.scheduling.quartz.JobDetailBean;
import org.springframework.scheduling.quartz.QuartzJobBean;

import com.prosodie.tools.alarm.AlarmDef;
import com.prosodie.tools.alarm.AlarmExploit;

/**
 * <p>
 * Job Launcher used to start scheduled Spring Batch Jobs.<br/>
 * <br/>
 * SVN-Author : $LastChangedBy: cdue $<br/>
 * SVN-Date : $LastChangedDate: 2013-03-27 09:12:22 +0100 (Wed, 27 Mar 2013) $<br/>
 * SVN-Revision : $LastChangedRevision: 1388 $<br/>
 * SVN-Header : $HeadURL:
 * https://svn.prosodie/NCA/trunk/NCAScheduler/src/com/prosodie
 * /nca/scheduler/JobLauncherDetails.java $<br/>
 * SVN-Id : $Id: JobLauncherDetails.java 1388 2013-03-27 08:12:22Z cdue $<br/>
 * </p>
 * 
 * @author cdue
 * @since v1.0.0
 */

@DisallowConcurrentExecution
public class JobLauncherDetails extends QuartzJobBean /*implements JobExecutionListener*/ {

	private static final String JOB_DATA_MAP_MAX_RETRY = "maxRetry";
	//private static final String JOB_DATA_MAP_NB_RETRIES = "nbRetries";
	private final static String JOB_LOCATOR_CONTEXT_KEY = "jobLocator";
	private final static String JOB_LAUNCHER_CONTEXT_KEY = "jobLauncher";
	private static final String JOB_DATA_MAP_START_DATE = "startDate";
	private static final String JOB_PARAM_LISTENER_DELAY_KEY = "listenerDelay";
	private static final long JOB_PARAM_DEFAULT_LISTENER_DELAY = 1000;

	private static Logger log = LoggerFactory.getLogger(JobLauncherDetails.class);

	/**
	 * Special key in job data map for the name of a job to run.
	 */
	private static final String JOB_NAME = "jobName";

	private JobLocator jobLocator;
	private JobLauncher jobLauncher;
	private String jobName;
    private JobListener MyjobListener;
	/**
	 * Method called by Quartz trigger. The given {@link JobExecutionContext}
	 * gives info on the Job to run.
	 */
	protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
		try {
			jobLocator = (JobLocator) context.getScheduler().getContext().get(JOB_LOCATOR_CONTEXT_KEY);
			jobLauncher = (JobLauncher) context.getScheduler().getContext().get(JOB_LAUNCHER_CONTEXT_KEY);
			MyjobListener=(JobListener)context.getScheduler().getContext().get(MyjobListener);
			
		
		} catch (SchedulerException se) {
			log.error("Unable to get jobLocator and jobLauncher from scheduler context.", se);
		}

		if (jobLocator == null || jobLauncher == null) {
			log.error("Unable to run a job without valids jobLocator and jobLauncher.");
		} else {
			JobDetail jobDetail = context.getJobDetail();
			Map<String, Object> jobDataMap = context.getMergedJobDataMap();
			
			if (jobDataMap == null || jobDataMap.size() == 0) {
				log.error("Unable to run a job without a valid jobDataMap (no job name provided...).");
			} else {
				
				jobName = (String) jobDataMap.get(JOB_NAME);

				if (jobName == null || jobName.isEmpty()) {
					log.error("Unable to run a job: no job name provided...");
				} else {
					
					if(context.getRefireCount()==0) {
						// Add a date to the jobDataMap so that the job is unique.
						// It is useful to distinguish 2 instances of the same trigger.
						// Otherwise, a JobExecutionAlreadyRunningException will be launched
						// (no need to modify this parameter for a refired job)
						jobDataMap.put(JOB_DATA_MAP_START_DATE, new Date());
					}

					JobParameters jobParameters = getJobParametersFromJobMap(jobDataMap);
		Scheduler sched= context.getScheduler();
		try {
			sched.getListenerManager().addJobListener(MyjobListener);
			
		} catch (SchedulerException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
//					sched.addJobListener(new NcaJobListener());
//					( jobDetail).addJobListener("LISTENER_NAME ");
					
					if (log.isInfoEnabled())
						log.info("\n**********************************************************************\n" 
								+ "* Quartz trigger - start job: {}. Key: {}\n"
								+ "* Firing unique ID: {}\n" 
								+ "* Refire count: {}\n" 
								+ "* Job parameters: {}\n"
								+ "* isConcurrentExectionDisallowed: {}\n"
								+ "**********************************************************************\n",
								new Object[] { jobName, jobDetail==null?"":jobDetail.getKey(), context.getFireInstanceId(), 
												context.getRefireCount(), jobParameters==null?"":jobParameters.toString(), 
												context.getJobDetail().isConcurrentExectionDisallowed() });
					
					JobExecution jobExec = null;
					BatchStatus jobStatus = BatchStatus.UNKNOWN;

					try {
						jobExec = jobLauncher.run(jobLocator.getJob(jobName), jobParameters);
						log.info("Job Id: {}", jobExec.getId());

						Long delayBetweenCheck = null;
						String delayBetweenCheckAsString = (String) jobDataMap.get(JOB_PARAM_LISTENER_DELAY_KEY);
						if(delayBetweenCheckAsString!=null && !delayBetweenCheckAsString.isEmpty()) {
							delayBetweenCheck = Long.valueOf(delayBetweenCheckAsString);
						}
						
						if(delayBetweenCheck==null)
							delayBetweenCheck = JOB_PARAM_DEFAULT_LISTENER_DELAY;
						
						// Start a while loop to check job status, as we cannot use a JobListener to check it 
						// (The job is running in a thread so we're not able to know it ends. 
						// In our case, JobListener.jobWasExecuted() is thrown as soon as the job is executed, not when it ends) 
						while (jobExec.isRunning()) {
							log.debug("********************* Job (Id: {}) is still runnning", jobExec.getId());
							
							Thread.sleep(delayBetweenCheck);
							Thread.yield();
						}

						jobStatus = jobExec.getStatus();
						
						if (BatchStatus.FAILED.equals(jobStatus)) {
							log.error("********************* Job (Id: {}) Failed, rescheduling if possible...", jobExec.getId());
							rescheduleJob(jobExec, context);
						}

					} catch (Exception ex) {
						if(!(ex instanceof JobExecutionException)) {
							log.error("Error while running Job [{}]. Rescheduling if possible.\nError: {}\n******************************", jobName, ex.toString());
							// TODO: retirer ce log...
							log.error("Error full stack:", ex);
							
							rescheduleJob(jobExec, context,  ex);
						} else {
							throw (JobExecutionException) ex;
						}
					}

					if (log.isInfoEnabled())
						log.info("\n**********************************************************************\n" 
								+ "* Quartz trigger - end job: {}\n"
								+ "* Firing unique ID: {}\n" 
								+ "* Refire count: {}\n" 
								+ "* Job parameters: {}\n"
								+ "* Start date: {}\n"
								+ "* End date: {}\n"
								+ "* Status: {}\n"
								+ "**********************************************************************\n",
								new Object[] { jobName, context.getFireInstanceId(), context.getRefireCount(), 
												jobParameters==null?"":jobParameters.toString(),
												jobExec==null?"":jobExec.getStartTime().toString(),
												jobExec==null?"":jobExec.getEndTime().toString(),
												jobStatus });
				}
			}
		}
	}

	private void rescheduleJob(JobExecution jobExec, JobExecutionContext context) throws JobExecutionException {
		rescheduleJob(jobExec, context, null);
	}

	private void rescheduleJob(JobExecution jobExec, JobExecutionContext context, Throwable excep) throws JobExecutionException {
		// TODO: Gérer la politique de réessai, ex :
		// http://stackoverflow.com/questions/4408858/quartz-retry-when-failure
		// peut être utiliser un listener :
		// http://forums.terracotta.org/forums/posts/list/6054.page
		// Penser à mettre le trigger en pause si job non concurrent -->
		// D'ailleurs il faut gérer cette non concurrence...
		
		if(jobExec == null)
			throw new IllegalArgumentException("jobExec cannot be null.");
		
		if(context == null)
			throw new IllegalArgumentException("context cannot be null.");
		
		String fireInstanceId =   context.getFireInstanceId();
		int refireCount = context.getRefireCount();
		
		if (log.isInfoEnabled())
			log.info("\n**********************************************************************\n" 
					+ "* Quartz trigger - rescheduling job: {}\n"
					+ "* Firing unique ID: {}\n" 
					+ "* Refire count: {}\n" 
					+ "**********************************************************************\n",
					new Object[] { jobName, fireInstanceId, refireCount});
		
		JobDataMap dataMap = context.getJobDetail().getJobDataMap();
		int maxRetry = dataMap.getIntValue(JOB_DATA_MAP_MAX_RETRY);
        //int nbRetries = dataMap.getIntValue(JOB_DATA_MAP_NB_RETRIES);
		
		JobExecutionException jobExecutionException = null;
		
        if(maxRetry>0 && refireCount<maxRetry) {        	
        	jobExecutionException = new JobExecutionException("Error: the job [" + jobName + "] didn't end properly, refire it immediately.", excep);
        	jobExecutionException.setRefireImmediately(true);
        	//boolean refireImmediatelyResult = jobExecutionException.refireImmediately();
        	
        	log.info("************** Job Id: {} - rescheduled. ", jobExec.getId());
        	
        	throw jobExecutionException;
        } else {
        	//jobExecutionException = new JobExecutionException("Error: the job [" + jobName + "] didn't end properly. No more retry possible, sending alarm.", excep);
        	//jobExecutionException.setRefireImmediately(false);
        	//jobExecutionException.setUnscheduleFiringTrigger(true);
        	
        	log.error("\n**********************************************************************\n" 
					+ "* Quartz trigger - No more retry possible for job: {}\n"
					+ "* Firing unique ID: {}\n" 
					+ "* UNSCHEDULING TRIGGER + SENDING EXPLOIT ALARM...\n"
					+ "**********************************************************************\n",
					jobName, fireInstanceId);
        	
        	AlarmDef alarmDef = AlarmExploit.searchBatchFailedAlarmDefByBatchName(jobName);
        	AlarmExploit.generateAlarmWithoutTemplate(alarmDef, "Batch failed", "The following batch failed (no more retry possible): " + jobName, Locale.ENGLISH.toString(), null);
        }
	}

	/**
	 * Copy parameters that are of the correct type over to
	 * {@link JobParameters}, ignoring jobName.
	 * 
	 * @return a {@link JobParameters} instance
	 */
	private JobParameters getJobParametersFromJobMap(Map<String, Object> jobDataMap) {

		JobParametersBuilder builder = new JobParametersBuilder();

		for (Entry<String, Object> entry : jobDataMap.entrySet()) {
			String key = entry.getKey();
			Object value = entry.getValue();
			if (value instanceof String && !key.equals(JOB_NAME)) {
				builder.addString(key, (String) value);
			} else if (value instanceof Float || value instanceof Double) {
				builder.addDouble(key, ((Number) value).doubleValue());
			} else if (value instanceof Integer || value instanceof Long) {
				builder.addLong(key, ((Number) value).longValue());
			} else if (value instanceof Date) {
				builder.addDate(key, (Date) value);
			} else {
				log.debug("JobDataMap contains values which are not job parameters (ignoring).");
			}
		}

		return builder.toJobParameters();
	}

	/*@Override
	public void afterJob(JobExecution jobExecution) {
		// TODO Auto-generated method stub
		log.info("*************************** Job ended with status: {} ********************", jobExecution.getExitStatus());

		if (ExitStatus.FAILED.equals(jobExecution.getExitStatus())) {
			log.error("******************************\nJob [{}] failed. Reschedule if possible.\n******************************", jobName);

			// rescheduleJob(jobExecution);
		}
	}

	@Override
	public void beforeJob(JobExecution jobExecution) {
		log.info("************** Before running job {} **************", jobName);
	}*/

}

what do you do for to notifate my job or how to use my class JobListener in my class lancher.
Thanks a lot