JarCastingquartz-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();
}
}