JAVA EE: Spring+Quartz Scheduler Integration Example (JobDetailFactoryBean)

Tuesday 18 December 2018

Spring+Quartz Scheduler Integration Example (JobDetailFactoryBean) | Spring Tutorial

Click here to watch on Youtube:
https://www.youtube.com/watch?v=G22H6Y5Ig3U&list=UUhwKlOVR041tngjerWxVccw

Click the below Image to Enlarge:

Spring+Quartz Scheduler Integration Example (JobDetailFactoryBean) | Spring Tutorial

pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0"

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

    <modelVersion>4.0.0</modelVersion>

    <groupId>com.ram.core</groupId>

    <artifactId>SpringDemo</artifactId>

    <packaging>jar</packaging>

    <version>1.0-SNAPSHOT</version>

    <name>SpringDemo</name>

    <url>http://maven.apache.org</url>

    <properties>

        <springframework.version>5.1.2.RELEASE</springframework.version>

        <quartz.version>2.3.0</quartz.version>

    </properties>

    <dependencies>

        <dependency>

            <groupId>org.springframework</groupId>

            <artifactId>spring-core</artifactId>

            <version>${springframework.version}</version>

        </dependency>

        <dependency>

            <groupId>org.springframework</groupId>

            <artifactId>spring-context-support</artifactId>

            <version>${springframework.version}</version>

        </dependency>

        <!-- Transaction dependency is required with Quartz integration -->

        <dependency>

            <groupId>org.springframework</groupId>

            <artifactId>spring-tx</artifactId>

            <version>${springframework.version}</version>

        </dependency>

        <!-- Quartz framework -->

        <dependency>

            <groupId>org.quartz-scheduler</groupId>

            <artifactId>quartz</artifactId>

            <version>${quartz.version}</version>

        </dependency>

    </dependencies>

</project>

ReportCurrentTime.java

package com.ram.scheduling;

import java.text.SimpleDateFormat;

import java.util.Date;

import org.springframework.stereotype.Component;

@Component("reportCurrentTime")

public class ReportCurrentTime

{

    private static final SimpleDateFormat dateFormat = new SimpleDateFormat(

            "HH:mm:ss");

    public void printCurrentTime()

    {

        System.out.println(

                "Current time = " + dateFormat.format(new Date()));

    }

}

ScheduledJob.java

package com.ram.quartz;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

import org.springframework.scheduling.quartz.QuartzJobBean;

import com.ram.scheduling.ReportCurrentTime;

public class ScheduledJob extends QuartzJobBean

{

    private ReportCurrentTime reportCurrentTime;

    @Override

    protected void executeInternal(JobExecutionContext arg0)

            throws JobExecutionException

    {

        reportCurrentTime.printCurrentTime();

    }

    public ReportCurrentTime getReportCurrentTime()

    {

        return reportCurrentTime;

    }

    public void setReportCurrentTime(

            ReportCurrentTime reportCurrentTime)

    {

        this.reportCurrentTime = reportCurrentTime;

    }

}

quartz-context.xml

<?xml version="1.0" encoding="UTF-8"?>

<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"

    xsi:schemaLocation="http://www.springframework.org/schema/beans 

    http://www.springframework.org/schema/beans/spring-beans-4.0.xsd

    http://www.springframework.org/schema/context 

    http://www.springframework.org/schema/context/spring-context-4.0.xsd">

    <context:component-scan base-package="com.ram" />

    <!-- For times when you need more complex processing, passing data to the 

        scheduled job -->

    <bean name="complexJobDetail"

        class="org.springframework.scheduling.quartz.JobDetailFactoryBean">

        <property name="jobClass" value="com.ram.quartz.ScheduledJob" />

        <property name="jobDataMap">

            <map>

                <entry key="reportCurrentTime" value-ref="reportCurrentTime" />

            </map>

        </property>

        <property name="durability" value="true" />

    </bean>

    <!-- Daily run the job every 5 seconds -->

    <bean id="cronTrigger"

        class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">

        <property name="jobDetail" ref="complexJobDetail" />

        <property name="cronExpression" value="0/5 * * ? * MON-SUN" />

    </bean>

    <!-- Scheduler factory bean to glue together jobDetails and triggers to 

        Configure Quartz Scheduler -->

    <bean

        class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

        <property name="jobDetails">

            <list>

                <ref bean="complexJobDetail" />

            </list>

        </property>

        <property name="triggers">

            <list>

                <ref bean="cronTrigger" />

            </list>

        </property>

    </bean>

</beans>

App.java

package com.ram;

import org.springframework.context.support.AbstractApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class App

{

    public static void main(String args[])

    {

        AbstractApplicationContext context = new ClassPathXmlApplicationContext(

                "quartz-context.xml");

    }

}

Output

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".

SLF4J: Defaulting to no-operation (NOP) logger implementation

SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.

Current time = 10:44:05

Current time = 10:44:10

Current time = 10:44:15

Current time = 10:44:20