Index: src/java/org/apache/nutch/indexer/IndexingFiltersChecker.java
===================================================================
--- src/java/org/apache/nutch/indexer/IndexingFiltersChecker.java	(revision 5050)
+++ src/java/org/apache/nutch/indexer/IndexingFiltersChecker.java	(working copy)
@@ -170,7 +170,8 @@
     public void run() {
       if (keepClientCnxOpen) {
         while (true) { // keep connection open until closes
-          readWrite();
+          boolean s = readWrite();
+          if (!s) return;
         }
       } else {
         readWrite();
@@ -183,7 +184,7 @@
       }
     }
     
-    protected void readWrite() {
+    protected boolean readWrite() {
       String line;
       BufferedReader in = null;
       PrintWriter out = null;
@@ -203,10 +204,12 @@
         client.getOutputStream().write(output.toString().getBytes(Charset.forName("UTF-8")));
       }catch (Exception e) {
         LOG.error("Read/Write failed: " + e);
+        return false;
       }
+      
+      return true;
     }
   }
-    
   
   protected int fetch(String url, StringBuilder output) throws Exception {
     if (normalizers != null) {