Author: mattmann
Date: Tue Feb 17 22:07:43 2015
New Revision: 1660516

URL: http://svn.apache.org/r1660516
Log:
- OODT-818 CmdLineIngester should log there was an exception and move on during 
ingest

Modified:
    oodt/trunk/CHANGES.txt
    
oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/ingest/StdIngester.java

Modified: oodt/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/oodt/trunk/CHANGES.txt?rev=1660516&r1=1660515&r2=1660516&view=diff
==============================================================================
--- oodt/trunk/CHANGES.txt (original)
+++ oodt/trunk/CHANGES.txt Tue Feb 17 22:07:43 2015
@@ -2,6 +2,8 @@ Apache OODT Change Log
 ======================
 Release 0.9 - Current Development
 
+* OODT-818 CmdLineIngester should log there was an exception and move on 
during ingest (mattmann)
+
 * OODT-817 TikaCmdLineExtractor needs to add Filename and FileLocation fields 
(mattmann)
 
 * OODT-813 CAS-PGE incorrectly passes varargs to DynamicConfigFile 
implementations (mattmann)

Modified: 
oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/ingest/StdIngester.java
URL: 
http://svn.apache.org/viewvc/oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/ingest/StdIngester.java?rev=1660516&r1=1660515&r2=1660516&view=diff
==============================================================================
--- 
oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/ingest/StdIngester.java
 (original)
+++ 
oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/ingest/StdIngester.java
 Tue Feb 17 22:07:43 2015
@@ -108,26 +108,38 @@ public class StdIngester implements Inge
         return ingest(fmUrl, prodFile, met);
     }
 
-    /*
-     * (non-Javadoc)
-     * 
-     * @see org.apache.oodt.cas.filemgr.ingest.Ingester#ingest(java.net.URL,
-     *      java.util.List, org.apache.oodt.cas.metadata.MetExtractor,
-     *      java.io.File)
-     */
-    public void ingest(URL fmUrl, List<String> prodFiles, MetExtractor 
extractor,
-            File metConfFile) throws IngestException {
-        if (prodFiles != null && prodFiles.size() > 0) {
-            for (Iterator<String> i = prodFiles.iterator(); i.hasNext();) {
-                String prodFilePath = i.next();
-                String productID = ingest(fmUrl, new File(prodFilePath),
-                        extractor, metConfFile);
-                LOG.log(Level.INFO, "Product: [" + prodFilePath
-                        + "] ingested successfully! ID: [" + productID + "]");
-            }
-        }
+       /*
+        * (non-Javadoc)
+        * 
+        * @see org.apache.oodt.cas.filemgr.ingest.Ingester#ingest(java.net.URL,
+        * java.util.List, org.apache.oodt.cas.metadata.MetExtractor, 
java.io.File)
+        */
+       public void ingest(URL fmUrl, List<String> prodFiles,
+                       MetExtractor extractor, File metConfFile) throws 
IngestException {
+               if (prodFiles != null && prodFiles.size() > 0) {
+                       for (Iterator<String> i = prodFiles.iterator(); 
i.hasNext();) {
+                               String prodFilePath = i.next();
+                               String productID = null;
 
-    }
+                               try {
+                                       productID = ingest(fmUrl, new 
File(prodFilePath),
+                                                       extractor, metConfFile);
+                                       LOG.log(Level.INFO, "Product: [" + 
prodFilePath
+                                                       + "] ingested 
successfully! ID: [" + productID
+                                                       + "]");
+                               } catch (IngestException e) {
+                                       LOG.log(Level.WARNING,
+                                                       "IngestException 
handling product: ["
+                                                                       + 
prodFilePath
+                                                                       + "]: 
Exception: ["
+                                                                       + 
e.getMessage()
+                                                                       + "]: 
Continuing ingest of remainder of products.");
+                               }
+
+                       }
+               }
+
+       }
 
     /*
      * (non-Javadoc)


Reply via email to