X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=crawler%2Fkissweb%2Fsrc%2Forg%2Fwamblee%2Fcrawler%2Fkiss%2Fscheduling%2Fquartz%2FQuartzCrawlerScheduler.java;h=94201f37b23213d08c3b47b9a03379da456ae46a;hb=26ae3728e2da2d86fe42994b9223fe44690dbfd0;hp=9458d1c38de982616bf3a44dcb3bea4fd79c5d57;hpb=0ee323ba44aa1653e9daf2e2ebe71ff15d9202f8;p=utils diff --git a/crawler/kissweb/src/org/wamblee/crawler/kiss/scheduling/quartz/QuartzCrawlerScheduler.java b/crawler/kissweb/src/org/wamblee/crawler/kiss/scheduling/quartz/QuartzCrawlerScheduler.java index 9458d1c3..94201f37 100644 --- a/crawler/kissweb/src/org/wamblee/crawler/kiss/scheduling/quartz/QuartzCrawlerScheduler.java +++ b/crawler/kissweb/src/org/wamblee/crawler/kiss/scheduling/quartz/QuartzCrawlerScheduler.java @@ -32,14 +32,18 @@ import org.quartz.impl.StdSchedulerFactory; public class QuartzCrawlerScheduler { private Scheduler _scheduler; + + private int _intervalInSeconds; /** * Constructs the quartz interface. + * @param aIntervalInSeconds Scheduling interval in seconds. * @throws SchedulerException */ - public QuartzCrawlerScheduler() throws SchedulerException { + public QuartzCrawlerScheduler(int aIntervalInSeconds) throws SchedulerException { SchedulerFactory schedulerFactory = new StdSchedulerFactory(); _scheduler = schedulerFactory.getScheduler(); + _intervalInSeconds = aIntervalInSeconds; } /** @@ -50,10 +54,9 @@ public class QuartzCrawlerScheduler { _scheduler.start(); JobDetail jobDetail = new JobDetail("kisscrawler", null, CrawlerJob.class); - jobDetail.getJobDataMap().put("count", 0); - - Trigger trigger = TriggerUtils.makeHourlyTrigger(); - trigger.setStartTime(TriggerUtils.getEvenHourDate(new Date())); + Trigger trigger = TriggerUtils.makeSecondlyTrigger(_intervalInSeconds); + //trigger.setStartTime(TriggerUtils.getEvenHourDate(new Date())); + trigger.setStartTime(new Date()); trigger.setName("hourly"); _scheduler.scheduleJob(jobDetail, trigger);