Throwable and Error should not be caught

src/main/java/org/xbib/elasticsearch/common/util/PlainIndexableObject.java

@@ -165,7 +165,7 @@ protected XContentBuilder toXContent(XContentBuilder builder, Params params, Map
             } else {
                 try {
                     builder.value(o);
-                } catch (Throwable e) {
+                } catch (Exception e) {
                     throw new IOException("unknown object class for value:" + o.getClass().getName() + " " + o);
                 }
             }

src/main/java/org/xbib/elasticsearch/jdbc/strategy/standard/StandardContext.java

@@ -186,7 +186,7 @@ public void fetch() throws Exception {
         logger.debug("fetch");
         try {
             getSource().fetch();
-        } catch (Throwable e) {
+        } catch (Exception e) {
             setThrowable(e);
             logger.error(e.getMessage(), e);
         }
@@ -198,13 +198,13 @@ public void afterFetch() throws Exception {
         writeState();
         try {
             getSource().afterFetch();
-        } catch (Throwable e) {
+        } catch (Exception e) {
             setThrowable(e);
             logger.error(e.getMessage(), e);
         }
         try {
             getSink().afterFetch();
-        } catch (Throwable e) {
+        } catch (Exception e) {
             setThrowable(e);
             logger.error(e.getMessage(), e);
         }

src/main/java/org/xbib/elasticsearch/jdbc/strategy/standard/StandardSource.java

@@ -929,7 +929,7 @@ public StandardSource<C> register(CallableStatement statement, Map<String, Objec
                     logger.debug("registerOutParameter: n={} type={}", n, toJDBCType(type));
                     try {
                         statement.registerOutParameter(n, toJDBCType(type));
-                    } catch (Throwable t) {
+                    } catch (Exception e) {
                         logger.warn("can't register out parameter " + n + " of type " + type);
                     }
                 }

src/main/java/org/xbib/pipeline/AbstractPipeline.java

@@ -53,7 +53,7 @@ public R call() throws Exception {
             close();
         } catch (InterruptedException e) {
             logger.warn("interrupted");
-        } catch (Throwable t) {
+        } catch (Exception t) {
             logger.error(t.getMessage(), t);
             throw t;
         }

src/main/java/org/xbib/tools/Importer.java

@@ -146,15 +146,15 @@ public void run(boolean bootstrap) {
             } else {
                 execute();
             }
-        } catch (Throwable e) {
+        } catch (Exception e) {
             logger.error(e.getMessage(), e);
         } finally {
             try {
                 cleanup();
                 if (executor != null) {
                     executor.shutdown();
                 }
-            } catch (Throwable e) {
+            } catch (Exception e) {
                 logger.warn(e.getMessage(), e);
             }
         }
@@ -165,15 +165,15 @@ public void run() {
         try {
             prepare();
             execute();
-        } catch (Throwable e) {
+        } catch (Exception e) {
             logger.error(e.getMessage(), e);
         } finally {
             try {
                 cleanup();
                 if (executor != null) {
                     executor.shutdown();
                 }
-            } catch (Throwable e) {
+            } catch (Exception e) {
                 logger.warn(e.getMessage(), e);
             }
         }

src/main/java/org/xbib/tools/Runner.java

@@ -27,7 +27,7 @@ public static void main(String[] args) {
             InputStream in = args.length > 1 ? new FileInputStream(args[1]) : System.in;
             commandLineInterpreter.reader("args", in).run(true);
             in.close();
-        } catch (Throwable e) {
+        } catch (Exception e) {
             e.printStackTrace();
             System.exit(1);
         }