60e59e83dbb40746fc06e32856a21d2f78c708ca
[utils] /
1 /*
2  * Copyright 2006 the original author or authors.
3  * 
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  * 
8  *      http://www.apache.org/licenses/LICENSE-2.0
9  * 
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16
17 package org.wamblee.crawler.kiss.scheduling.quartz;
18
19 import org.apache.commons.logging.Log;
20 import org.apache.commons.logging.LogFactory;
21 import org.quartz.JobExecutionContext;
22 import org.quartz.JobExecutionException;
23 import org.quartz.StatefulJob;
24 import org.wamblee.crawler.kiss.scheduling.CrawlerStatus;
25 import org.wamblee.general.BeanKernel;
26
27 /**
28  * Quartz job to execute the crawler.  
29  */
30 public class CrawlerJob implements StatefulJob {
31
32     private static final Log LOG = LogFactory.getLog(CrawlerJob.class);
33
34     /**
35      * Constructs the job.
36      *
37      */
38     public CrawlerJob() {
39         // Empty.
40     }
41
42     /*
43      * (non-Javadoc)
44      * 
45      * @see org.quartz.Job#execute(org.quartz.JobExecutionContext)
46      */
47     public void execute(JobExecutionContext aContext)
48             throws JobExecutionException {
49         LOG.info("Job triggered");
50         try {
51             CrawlerStatus schedule = BeanKernel.getBeanFactory().find(
52                     CrawlerStatus.class);
53             schedule.execute(aContext.getFireTime());
54         } catch (Exception e) {
55             throw new JobExecutionException("Error executing crawler", e, false);
56         }
57     }
58 }