Using Quartz with SOA Suite 11g
Already in 2006 Clemens posted on scheduling BPEL processes. More recently with BPEL in SOA Suite 11g a bug ( 8927175: PROVIDE QUARTZ SCHEDULER) was submitted. The rquest text:
The product does not have schedular to schedule BPEL processes. Need to schedule the BPEL processes through SOA11G and not through unsupported softwares(Quartz).
And the business need:
Some processes need to be scheduled at a particular time and at a particular day and should not be started Manually, increases the maintenance cost of the software.
These together indicate a clear need to schedule reoccurring processes. Although I’m not so sure that this functionality should be provided by this platform. One could see advantages in centralizing all scheduling task. There a good commercial product available for cases like that (Redwood’s Cronacle for example).
On Oracle Technet there is a good document on Configure a SOAScheduler for a composite in SOA Suite 11.
One Job, multiple Schedules
We need a Class that implements Job. Something like:
package net.deltalounge.quartzdemo; import java.util.Map; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.quartz.SchedulerException; public class DemoJob implements Job { public DemoJob() { super(); } public void execute(JobExecutionContext context) { Map dataMap = context.getJobDetail().getJobDataMap(); RunMeTask task = new RunMeTask(); String someString ="init"; someString = context.getTrigger().getName(); System.out.println("Quartz demo output: "+someString); } }
And we need a Class that creates and starts the Scheduler. This Class can also schedule the jobs. Here we actually see that although one Job Class is enough we need to declare mutiple JobDetails.
package net.deltalounge.quartzdemo; import java.util.Map; import org.quartz.CronTrigger; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.impl.StdSchedulerFactory; public class QuartzAppCronTrigger { public static void main( String[] args ) throws Exception { //scheduler task details JobDetail job = new JobDetail(); job.setName("someJob"); job.setJobClass(DemoJob.class); // JobDetail job2 = new JobDetail(); job2.setName("someOtherJob"); job2.setJobClass(DemoJob.class); //configure scheduler time CronTrigger trigger = new CronTrigger(); trigger.setName("someJobTrigger"); trigger.setCronExpression("0/30 * * * * ?"); //configure scheduler time 2 CronTrigger trigger2 = new CronTrigger(); trigger2.setName("someOtherTrigger"); trigger2.setCronExpression("0/20 * * * * ?"); //create the schedule Scheduler scheduler = new StdSchedulerFactory().getScheduler(); scheduler.start(); scheduler.scheduleJob(job, trigger); scheduler.scheduleJob(job2, trigger2); } }
If you don’t define multiple jobs prepare for an error like:
Exception in thread "main" org.quartz.ObjectAlreadyExistsException: Unable to store Job with name: 'someJob' and group: 'DEFAULT', because one already exists with this identification. at org.quartz.simpl.RAMJobStore.storeJob(RAMJobStore.java:222) at org.quartz.simpl.RAMJobStore.storeJobAndTrigger(RAMJobStore.java:195) at org.quartz.core.QuartzScheduler.scheduleJob(QuartzScheduler.java:732) at org.quartz.impl.StdScheduler.scheduleJob(StdScheduler.java:265) at net.deltalounge.quartzdemo.QuartzAppCronTrigger.main(QuartzAppCronTrigger.java:36)
