You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@manifoldcf.apache.org by kw...@apache.org on 2015/01/29 13:30:10 UTC
svn commit: r1655618 -
/manifoldcf/trunk/connectors/webcrawler/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/webcrawler/ThrottledFetcher.java
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);
}
}