Skip to content

Commit 413aa9f

Browse files
author
Stephane Landelle
committed
Move PerHostConnectionPoolPartitioning inside ConnectionPoolPartitioning, close AsyncHttpClient#737
1 parent 8f18bea commit 413aa9f

File tree

3 files changed

+13
-31
lines changed

3 files changed

+13
-31
lines changed

api/src/main/java/org/asynchttpclient/ConnectionPoolPartitioning.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,20 @@
1616
package org.asynchttpclient;
1717

1818
import org.asynchttpclient.uri.Uri;
19+
import org.asynchttpclient.util.AsyncHttpProviderUtils;
1920

2021
public interface ConnectionPoolPartitioning {
2122

2223
String getPartitionId(Uri uri, ProxyServer proxy);
24+
25+
public enum PerHostConnectionPoolPartitioning implements ConnectionPoolPartitioning {
26+
27+
INSTANCE;
28+
29+
@Override
30+
public String getPartitionId(Uri uri, ProxyServer proxyServer) {
31+
String serverPart = AsyncHttpProviderUtils.getBaseUrl(uri);
32+
return proxyServer != null ? proxyServer.getUrl() + serverPart : serverPart;
33+
}
34+
}
2335
}

api/src/main/java/org/asynchttpclient/PerHostConnectionPoolPartitioning.java

Lines changed: 0 additions & 30 deletions
This file was deleted.

api/src/main/java/org/asynchttpclient/RequestBuilderBase.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ private static final class RequestImpl implements Request {
6666
private int requestTimeoutInMs;
6767
private long rangeOffset;
6868
public String charset;
69-
private ConnectionPoolPartitioning connectionPoolPartitioning = PerHostConnectionPoolPartitioning.INSTANCE;
69+
private ConnectionPoolPartitioning connectionPoolPartitioning = ConnectionPoolPartitioning.PerHostConnectionPoolPartitioning.INSTANCE;
7070
private List<Param> queryParams;
7171

7272
public RequestImpl() {

0 commit comments

Comments
 (0)