quartz-drink-guice

Quartz + Guice(Dependency Injection)

Getting started

Add dependency in your pom.xml or other build tool’s configuration file.

<dependency>
    <groupId>net.y-yuki</groupId>
    <artifactId>quartz-drink-guice</artifactId>
    <version>0.1.1</version>
</dependency>

Define a job class

import org.quartz.DisallowConcurrentExecution;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import javax.inject.Inject;
import javax.inject.Singleton;
@DisallowConcurrentExecution
@Singleton
public class MyJob implements org.quartz.Job {
    private final MyLogic logic;
    @Inject
    public MyJob(MyLogic logic) {
        this.logic = logic;
    }
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        logic.invoke();
    }
}

import com.google.inject.ImplementedBy;
@ImplementedBy(TrialQuartzImpl.class)
public interface TrialQuartz {
    void run();
}

import net.yyuki.quartz.ex.guice.QuartzEx;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import javax.inject.Inject;
import javax.inject.Singleton;
import static org.quartz.SimpleScheduleBuilder.simpleSchedule;
@Singleton
public class TrialQuartzImpl implements TrialQuartz {
    private final QuartzEx quartz;
    @Inject
    public TrialQuartzImpl(QuartzEx quartz) {
        this.quartz = quartz;
    }
    @Override
    public void run() {
        JobDetail job1 = JobBuilder.newJob(MyJob.class)
                .withIdentity("job1", "group1")
                .build();
        Trigger trigger1 = TriggerBuilder.newTrigger()
                .withIdentity("trigger1", "group1")
                .startNow()
                .withSchedule(simpleSchedule()
                        .withIntervalInMilliseconds(100)
                        .repeatForever())
                .build();
        Scheduler scheduler = quartz.getScheduler();
        try {
            scheduler.start();
            scheduler.scheduleJob(job1, trigger1);
        } catch (SchedulerException e) {
            throw new RuntimeException(e);
        }
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        try {
            scheduler.shutdown();
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }
}

DI Container start

import com.google.inject.Guice;
import com.google.inject.Injector;
import net.yyuki.quartz.ex.guice.QuartzModule;
public class QuartzTrialMain {
    public static void main(String[] args) throws Exception {
        Injector injector = Guice.createInjector(new QuartzModule());
        TrialQuartz trialQuartz = injector.getInstance(TrialQuartz.class);
        trialQuartz.run();
    }
}