Archives/Athou_commafeed
1
0
Fork 1
mirror of https://github.com/Athou/commafeed.git synced 2026-03-21 21:37:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

disable http retry manager

Browse Source
This commit is contained in:
Athou
2013-04-19 11:49:22 +02:00
parent 1ba9d32c9f
commit f8a7241bc1
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/com/commafeed/backend/HttpGetter.java
View File

@@ -14,6 +14,7 @@ import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.params.CookiePolicy; import org.apache.http.client.params.CookiePolicy;
import org.apache.http.client.params.HttpClientParams; import org.apache.http.client.params.HttpClientParams;
import org.apache.http.impl.client.DefaultHttpClient; import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.impl.client.DefaultHttpRequestRetryHandler;
import org.apache.http.params.HttpConnectionParams; import org.apache.http.params.HttpConnectionParams;
import org.apache.http.params.HttpParams; import org.apache.http.params.HttpParams;
import org.apache.http.params.HttpProtocolParams; import org.apache.http.params.HttpProtocolParams;
@@ -51,6 +52,9 @@ public class HttpGetter {
HttpProtocolParams.setContentCharset(params, "UTF-8"); HttpProtocolParams.setContentCharset(params, "UTF-8");
HttpConnectionParams.setConnectionTimeout(params, 4000); HttpConnectionParams.setConnectionTimeout(params, 4000);
HttpConnectionParams.setSoTimeout(params, 4000); HttpConnectionParams.setSoTimeout(params, 4000);
httpclient
.setHttpRequestRetryHandler(new DefaultHttpRequestRetryHandler(
0, false));
try { try {
HttpGet httpget = new HttpGet(url); HttpGet httpget = new HttpGet(url);
@@ -78,26 +82,26 @@ public class HttpGetter {
Header lastModifiedHeader = response Header lastModifiedHeader = response
.getFirstHeader(HttpHeaders.LAST_MODIFIED); .getFirstHeader(HttpHeaders.LAST_MODIFIED);
Header eTagHeader = response.getFirstHeader(HttpHeaders.ETAG); Header eTagHeader = response.getFirstHeader(HttpHeaders.ETAG);
HttpEntity entity = response.getEntity();
String lastModifiedResponse = lastModifiedHeader == null ? null String lastModifiedResponse = lastModifiedHeader == null ? null
: lastModifiedHeader.getValue(); : lastModifiedHeader.getValue();
String eTagResponse = eTagHeader == null ? null : eTagHeader
.getValue();
if (lastModified != null if (lastModified != null
&& StringUtils.equals(lastModified, lastModifiedResponse)) { && StringUtils.equals(lastModified, lastModifiedResponse)) {
throw new NotModifiedException(); throw new NotModifiedException();
} }
String eTagResponse = eTagHeader == null ? null : eTagHeader
.getValue();
if (eTag != null && StringUtils.equals(eTag, eTagResponse)) { if (eTag != null && StringUtils.equals(eTag, eTagResponse)) {
throw new NotModifiedException(); throw new NotModifiedException();
} }
HttpEntity entity = response.getEntity();
byte[] content = null; byte[] content = null;
if (entity != null) { if (entity != null) {
content = EntityUtils.toByteArray(entity); content = EntityUtils.toByteArray(entity);
} }
long duration = System.currentTimeMillis() - start; long duration = System.currentTimeMillis() - start;
result = new HttpResult(content, lastModifiedHeader == null ? null result = new HttpResult(content, lastModifiedHeader == null ? null
: lastModifiedHeader.getValue(), eTagHeader == null ? null : lastModifiedHeader.getValue(), eTagHeader == null ? null