\r
package jetbrains.buildServer.nuget.server.feed.reader.impl;\r
\r
+import org.apache.http.HttpResponse;\r
import org.apache.http.client.HttpClient;\r
+import org.apache.http.client.methods.HttpUriRequest;\r
import org.jetbrains.annotations.NotNull;\r
\r
+import java.io.IOException;\r
+\r
/**\r
* Created by Eugene Petrenko (eugene.petrenko@gmail.com)\r
* Date: 12.08.11 15:13\r
*/\r
public interface FeedClient {\r
@NotNull\r
- HttpClient getClient();\r
+ HttpResponse execute(@NotNull HttpUriRequest request) throws IOException;\r
}\r
package jetbrains.buildServer.nuget.server.feed.reader.impl;\r
\r
import jetbrains.buildServer.version.ServerVersionHolder;\r
+import org.apache.http.HttpResponse;\r
import org.apache.http.client.HttpClient;\r
+import org.apache.http.client.methods.HttpUriRequest;\r
import org.apache.http.impl.client.DefaultHttpClient;\r
import org.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager;\r
import org.apache.http.params.HttpConnectionParams;\r
import org.apache.http.params.HttpProtocolParams;\r
import org.jetbrains.annotations.NotNull;\r
\r
+import java.io.IOException;\r
+\r
/**\r
* Created by Eugene Petrenko (eugene.petrenko@gmail.com)\r
* Date: 11.08.11 16:24\r
return myClient;\r
}\r
\r
+ @NotNull\r
+ public HttpResponse execute(@NotNull HttpUriRequest request) throws IOException {\r
+ return myClient.execute(request);\r
+ }\r
+\r
public void dispose() {\r
myClient.getConnectionManager().shutdown();\r
}\r
\r
LOG.debug("Query for packages: " + get.getURI());\r
\r
- final HttpResponse execute = myClient.getClient().execute(get);\r
+ final HttpResponse execute = myClient.execute(get);\r
return myParser.readPackages(toDocument(execute));\r
}\r
\r
final String url = pkg.getDownloadUrl();\r
\r
final HttpGet get = myMethodFactory.createGet(url);\r
- final HttpResponse resp = myClient.getClient().execute(get);\r
+ final HttpResponse resp = myClient.execute(get);\r
final StatusLine statusLine = resp.getStatusLine();\r
if (statusLine.getStatusCode() != HttpStatus.SC_OK) {\r
throw new IOException("Failed to download package " + pkg + ". Server returned " + statusLine);\r
HttpGet ping = myMethods.createGet(feedUrl);\r
ping.getParams().setBooleanParameter(ClientPNames.HANDLE_REDIRECTS, false);\r
\r
- final HttpResponse execute = myClient.getClient().execute(ping);\r
+ final HttpResponse execute = myClient.execute(ping);\r
final int statusCode = execute.getStatusLine().getStatusCode();\r
if (statusCode / 100 == 3) {\r
final Header location = execute.getFirstHeader("Location");\r