Skip to content

Commit 84917f8

Browse files
author
Stephane Landelle
committed
Add another public constructor to NettyConnectionsPool that doesn't depend on NettyAsyncHttpProvider, close AsyncHttpClient#289
1 parent a346e8e commit 84917f8

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

src/main/java/com/ning/http/client/providers/netty/NettyConnectionsPool.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -42,10 +42,14 @@ public class NettyConnectionsPool implements ConnectionsPool<String, Channel> {
4242
private final long maxIdleTime;
4343

4444
public NettyConnectionsPool(NettyAsyncHttpProvider provider) {
45-
this.maxTotalConnections = provider.getConfig().getMaxTotalConnections();
46-
this.maxConnectionPerHost = provider.getConfig().getMaxConnectionPerHost();
47-
this.sslConnectionPoolEnabled = provider.getConfig().isSslConnectionPoolEnabled();
48-
this.maxIdleTime = provider.getConfig().getIdleConnectionInPoolTimeoutInMs();
45+
this(provider.getConfig().getMaxTotalConnections(), provider.getConfig().getMaxConnectionPerHost(), provider.getConfig().getIdleConnectionInPoolTimeoutInMs(), provider.getConfig().isSslConnectionPoolEnabled());
46+
}
47+
48+
public NettyConnectionsPool(int maxTotalConnections, int maxConnectionPerHost, long maxIdleTime, boolean sslConnectionPoolEnabled) {
49+
this.maxTotalConnections = maxTotalConnections;
50+
this.maxConnectionPerHost = maxConnectionPerHost;
51+
this.sslConnectionPoolEnabled = sslConnectionPoolEnabled;
52+
this.maxIdleTime = maxIdleTime;
4953
this.idleConnectionDetector.schedule(new IdleChannelDetector(), maxIdleTime, maxIdleTime);
5054
}
5155

0 commit comments

Comments
 (0)