--- src/java/org/apache/nutch/indexer/IndexingFiltersChecker.java	2016-06-01 12:34:24.172939181 +0200
+++ /home/markus/projects/openindex/nutch/trunk/scripts/apache-nutch-1.11/src/java/org/apache/nutch/indexer/IndexingFiltersChecker.java	2016-06-01 10:53:34.939988303 +0200
@@ -69,7 +69,6 @@
   protected URLNormalizers normalizers = null;
   protected boolean dumpText = false;
   protected boolean followRedirects = false;
-  protected boolean keepClientCnxOpen = false;
   // used to simulate the metadata propagated from injection
   protected HashMap<String, String> metadata = new HashMap<String, String>();
   protected int tcpPort = -1;
@@ -83,7 +82,7 @@
 
   public int run(String[] args) throws Exception {
     String url = null;
-    String usage = "Usage: IndexingFiltersChecker [-normalize] [-followRedirects] [-dumpText] [-md key=value] [-listen <port>] [-keepClientCnxOpen]";
+    String usage = "Usage: IndexingFiltersChecker [-normalize] [-followRedirects] [-dumpText] [-md key=value] [-listen <port>] <url>";
 
     if (args.length == 0) {
       System.err.println(usage);
@@ -97,8 +96,6 @@
         tcpPort = Integer.parseInt(args[++i]);
       } else if (args[i].equals("-followRedirects")) {
         followRedirects = true;
-      } else if (args[i].equals("-keepClientCnxOpen")) {
-        keepClientCnxOpen = true;
       } else if (args[i].equals("-dumpText")) {
         dumpText = true;
       } else if (args[i].equals("-md")) {
@@ -167,23 +164,7 @@
       LOG.info(client.toString());
     }
 
-    public void run() {
-      if (keepClientCnxOpen) {
-        while (true) { // keep connection open until closes
-          readWrite();
-        }
-      } else {
-        readWrite();
-        
-        try { // close ourselves
-          client.close();
-        } catch (Exception e){
-          LOG.error(e.toString());
-        }
-      }
-    }
-    
-    protected void readWrite() {
+    public void run(){
       String line;
       BufferedReader in = null;
       PrintWriter out = null;
@@ -204,6 +185,14 @@
       }catch (Exception e) {
         LOG.error("Read/Write failed: " + e);
       }
+      
+      try {
+        client.close();
+      } catch (Exception e){
+        LOG.error(e.toString());
+      }
+      
+      return;
     }
   }
     
@@ -342,8 +331,6 @@
         }
       }
     }
-    
-    output.append("\n"); // For readability if keepClientCnxOpen
 
     if (getConf().getBoolean("doIndex", false) && doc != null) {
       IndexWriters writers = new IndexWriters(getConf());
