svn commit: r1655618 - /manifoldcf/trunk/connectors/webcrawler/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/webcrawler/ThrottledFetcher.java

[kwright]

Author: kwright
Date: Thu Jan 29 12:30:10 2015
New Revision: 1655618

URL: http://svn.apache.org/r1655618
Log:
First part of CONNECTORS-1154 fix.

Modified:
    
manifoldcf/trunk/connectors/webcrawler/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/webcrawler/ThrottledFetcher.java

Modified: 
manifoldcf/trunk/connectors/webcrawler/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/webcrawler/ThrottledFetcher.java
URL: 
http://svn.apache.org/viewvc/manifoldcf/trunk/connectors/webcrawler/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/webcrawler/ThrottledFetcher.java?rev=1655618&r1=1655617&r2=1655618&view=diff
==============================================================================
--- 
manifoldcf/trunk/connectors/webcrawler/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/webcrawler/ThrottledFetcher.java
 (original)
+++ 
manifoldcf/trunk/connectors/webcrawler/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/webcrawler/ThrottledFetcher.java
 Thu Jan 29 12:30:10 2015
@@ -959,7 +959,7 @@ public class ThrottledFetcher
     {
       if (statusCode > 0)
       {
-        throwable = new ManifoldCFException("Interrupted: "+e.getMessage(),e);
+        throwable = new ManifoldCFException("Fetch interrupted: 
"+e.getMessage(),e);
         statusCode = FETCH_INTERRUPTED;
       }
     }
@@ -1079,8 +1079,8 @@ public class ThrottledFetcher
           currentTime + 720L * 60000L,-1,false);
       }
       long currentTime = System.currentTimeMillis();
-      Logging.connectors.debug("Web: IO exception "+activity+" for 
'"+myUrl+"', retrying");
-      throw new ServiceInterruption("IO exception "+activity+": 
"+e.getMessage(),e,currentTime+TIME_5MIN,-1L,2,false);
+      Logging.connectors.debug("Web: IO exception 
("+e.getClass().getName()+")"+activity+" for '"+myUrl+"', retrying",e);
+      throw new ServiceInterruption("IO exception 
("+e.getClass().getName()+")"+activity+": 
"+e.getMessage(),e,currentTime+TIME_5MIN,-1L,2,false);
     }
 
   }