(no commit message)
[utils] / crawler / kissweb / src / org / wamblee / crawler / kiss / scheduling / CrawlerExecutorImpl.java
index 35d3f923be224376c6d1524f3867c979867f1970..d807d57fc6c7ee68c69f5a2e23765fc9b440394f 100644 (file)
@@ -19,6 +19,8 @@ package org.wamblee.crawler.kiss.scheduling;
 import java.util.Date;
 
 import org.wamblee.crawler.kiss.main.KissCrawler;
+import org.wamblee.crawler.kiss.main.Report;
+import org.wamblee.crawler.kiss.notification.Notifier;
 
 /**
  * Implementation which executes the KiSS crawler for retrieving web content. 
@@ -26,22 +28,25 @@ import org.wamblee.crawler.kiss.main.KissCrawler;
 public class CrawlerExecutorImpl implements CrawlerExecutor {
     
     private String _crawlerConfig; 
-    private String _programConfig; 
-    
+    private String _programConfig;
+    private Notifier _notifier; 
+   
     /**
      * Constructs the crawler executor. 
      * @param aCrawlerConfig Crawler configuration file. 
-     * @param aProgramConfig Program configuration file. 
+     * @param aProgramConfig Program configuration file.
+     * @param aNotifier Object used to send notifications.  
      */
-    public CrawlerExecutorImpl(String aCrawlerConfig, String aProgramConfig) { 
+    public CrawlerExecutorImpl(String aCrawlerConfig, String aProgramConfig, Notifier aNotifier) { 
         _crawlerConfig = aCrawlerConfig; 
-        _programConfig = aProgramConfig; 
+        _programConfig = aProgramConfig;
+        _notifier = aNotifier;
     }
 
     /* (non-Javadoc)
      * @see org.wamblee.crawler.kiss.scheduling.CrawlerScheduler.CrawlerExecutor#execute(java.util.Date)
      */
-    public void execute(Date aDate) throws Exception {
-        KissCrawler crawler = new KissCrawler(_crawlerConfig, _programConfig);       
+    public void execute(Date aDate, Report aReport) throws Exception {
+        new KissCrawler(_crawlerConfig, _programConfig, _notifier, aReport);
     }
 }