Configurable maxPipeline for the extended worker.

rapidoid · Dec 11, 2017 · 21933b0 · 21933b0
1 parent 7d8aecd
commit 21933b0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/networking/rapidoid-net/src/main/java/org/rapidoid/net/impl/ExtendedWorker.java b/networking/rapidoid-net/src/main/java/org/rapidoid/net/impl/ExtendedWorker.java
@@ -83,7 +83,7 @@ public class ExtendedWorker extends AbstractEventLoop<ExtendedWorker> implements
 
 	private final Set<RapidoidConnection> allConnections = Coll.concurrentSet();
 
-	private final int maxPipeline;
+	private final long maxPipeline;
 
 	private final int selectorTimeout = 10;
 
@@ -131,7 +131,7 @@ public ExtendedWorker(String name, RapidoidHelper helper, NetworkingParams net,
 		this.helper = helper;
 		this.sslContext = sslContext;
 
-		this.maxPipeline = Conf.HTTP.entry("maxPipeline").or(10);
+		this.maxPipeline = net.maxPipeline();
 
 		final int queueSize = ConfigUtil.micro() ? 1000 : 1000000;
 		final int growFactor = ConfigUtil.micro() ? 2 : 10;