diff options
| -rw-r--r-- | vespa-feed-client/src/main/java/ai/vespa/feed/client/JettyCluster.java | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/JettyCluster.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/JettyCluster.java index eb52c3f9e27..56be53798b1 100644 --- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/JettyCluster.java +++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/JettyCluster.java @@ -28,7 +28,8 @@ class JettyCluster implements Cluster { JettyCluster(FeedClientBuilder builder) { for (URI endpoint : builder.endpoints) - endpoints.add(new Endpoint(createJettyHttpClient(builder), endpoint)); + for (int i = 0; i < builder.connectionsPerEndpoint; i++) + endpoints.add(new Endpoint(createJettyHttpClient(builder), endpoint)); } private static HttpClient createJettyHttpClient(FeedClientBuilder builder) { @@ -38,17 +39,13 @@ class JettyCluster implements Cluster { clientSslCtxFactory.setHostnameVerifier(builder.hostnameVerifier); HTTP2Client wrapped = new HTTP2Client(); - wrapped.setSelectors(8); wrapped.setMaxConcurrentPushedStreams(builder.maxStreamsPerConnection); HttpClientTransport transport = new HttpClientTransportOverHTTP2(wrapped); HttpClient client = new HttpClient(transport, clientSslCtxFactory); client.setUserAgentField(new HttpField("User-Agent", String.format("vespa-feed-client/%s", Vespa.VERSION))); - client.setDefaultRequestContentType("application/json"); client.setFollowRedirects(false); - client.setMaxRequestsQueuedPerDestination(builder.connectionsPerEndpoint * builder.maxStreamsPerConnection); - client.setIdleTimeout(10000); - client.setMaxConnectionsPerDestination(builder.connectionsPerEndpoint); - client.setRequestBufferSize(1 << 16); + client.setMaxRequestsQueuedPerDestination(builder.maxStreamsPerConnection); + client.setMaxConnectionsPerDestination(1); client.start(); return client; |