diff options
Diffstat (limited to 'vespa-feed-client/src/main/java/ai/vespa/feed/client/HttpFeedClient.java')
-rw-r--r-- | vespa-feed-client/src/main/java/ai/vespa/feed/client/HttpFeedClient.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/HttpFeedClient.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/HttpFeedClient.java index 370cd326f10..b3c711f7cc5 100644 --- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/HttpFeedClient.java +++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/HttpFeedClient.java @@ -45,7 +45,7 @@ class HttpFeedClient implements FeedClient { private final URI endpoint; private final Map<String, Supplier<String>> requestHeaders; - private final HttpRequestStrategy requestStrategy; + private final RequestStrategy requestStrategy; private final List<CloseableHttpAsyncClient> httpClients = new ArrayList<>(); private final List<AtomicInteger> inflight = new ArrayList<>(); private final AtomicBoolean closed = new AtomicBoolean(); @@ -56,14 +56,14 @@ class HttpFeedClient implements FeedClient { this.requestStrategy = new HttpRequestStrategy(builder); for (int i = 0; i < builder.maxConnections; i++) { - CloseableHttpAsyncClient client = createHttpClient(builder, requestStrategy); + CloseableHttpAsyncClient client = createHttpClient(builder); client.start(); httpClients.add(client); inflight.add(new AtomicInteger()); } } - private static CloseableHttpAsyncClient createHttpClient(FeedClientBuilder builder, HttpRequestStrategy retryStrategy) throws IOException { + private static CloseableHttpAsyncClient createHttpClient(FeedClientBuilder builder) throws IOException { H2AsyncClientBuilder httpClientBuilder = H2AsyncClientBuilder.create() .setUserAgent(String.format("vespa-feed-client/%s", Vespa.VERSION)) .setDefaultHeaders(Collections.singletonList(new BasicHeader("Vespa-Client-Version", Vespa.VERSION))) |