Quartz Scheduler with JobListener

JobListener is used to keep track of the running jobs status, like when the job is started and when it is about to be completed!!

1. Create a Quartz Job:

package com.tutorial.quartz;

import org.quartz.Job;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

public class HelloJob implements Job

{

public void execute(JobExecutionContext context)

throws JobExecutionException {

System.out.println("Hello Quartz Scheduler with Job Listener !!!");

}

}

Project Workspace: Overview

 

2. Create a Job Listener:

package com.tutorial.quartz;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

import org.quartz.JobListener;

public class HelloJobListener implements JobListener {

public static final String LISTENER_NAME = "sampleJobListenerName";

@Override

public String getName() {

return LISTENER_NAME;

}

@Override

public void jobToBeExecuted(JobExecutionContext context) {

System.out.println(context.getJobDetail().getKey().toString() + " Job is Started!!");

}

@Override

public void jobExecutionVetoed(JobExecutionContext context) {

System.out.println(context.getJobDetail().getKey().toString() + " Job is Terminated!!");

}

@Override

public void jobWasExecuted(JobExecutionContext context,

JobExecutionException jobException) {

System.out.println(context.getJobDetail().getKey().toString() + " Job execution Completed!!");

if (!jobException.getMessage().equals("")) {

System.out.println("Exception thrown by: " + context.getJobDetail().getKey().toString()

+ " Exception: " + jobException.getMessage());

}

}

}

3. Create JobKey, Trigger and Scheduler:

package com.tutorial.quartz;

import org.quartz.JobBuilder;

import org.quartz.JobDetail;

import org.quartz.JobKey;

import org.quartz.Scheduler;

import org.quartz.SimpleScheduleBuilder;

import org.quartz.Trigger;

import org.quartz.TriggerBuilder;

import org.quartz.impl.StdSchedulerFactory;

import org.quartz.impl.matchers.KeyMatcher;

public class SimpleTrigger {

public static void main(String[] args) throws Exception {

//Create a JobKey

JobKey jobKey = new JobKey("sampleJobName", "group1");

// Create a Job

JobDetail job = JobBuilder.newJob(HelloJob.class)

.withIdentity("sampleJobName", "group1").build();

// Trigger the job

Trigger trigger = TriggerBuilder

.newTrigger()

.withIdentity("sampleTriggerName", "group1")

.withSchedule(

SimpleScheduleBuilder.simpleSchedule()

.withIntervalInSeconds(5).repeatForever())

.build();

// Schedule the Job

Scheduler scheduler = new StdSchedulerFactory().getScheduler();

//Listener attached to the jobKey

scheduler.getListenerManager().addJobListener(

new HelloJobListener(), KeyMatcher.keyEquals(jobKey));

scheduler.start();

scheduler.scheduleJob(job, trigger);

}

}

Output:

References:

http://quartz-scheduler.org/documentation/quartz-2.1.x/cookbook/JobListeners