diff --git a/src/main/java/org/springframework/data/elasticsearch/client/RestClients.java b/src/main/java/org/springframework/data/elasticsearch/client/RestClients.java index 63f22ffa0..4f0ec06be 100644 --- a/src/main/java/org/springframework/data/elasticsearch/client/RestClients.java +++ b/src/main/java/org/springframework/data/elasticsearch/client/RestClients.java @@ -54,6 +54,7 @@ import org.springframework.util.Assert; * @author Huw Ayling-Miller * @author Henrique Amaral * @author Peter-Josef Meisch + * @author Nic Hines * @since 3.2 */ public final class RestClients { @@ -104,15 +105,14 @@ public final class RestClients { Duration connectTimeout = clientConfiguration.getConnectTimeout(); if (!connectTimeout.isNegative()) { - requestConfigBuilder.setConnectTimeout(Math.toIntExact(connectTimeout.toMillis())); - requestConfigBuilder.setConnectionRequestTimeout(Math.toIntExact(connectTimeout.toMillis())); } Duration timeout = clientConfiguration.getSocketTimeout(); if (!timeout.isNegative()) { requestConfigBuilder.setSocketTimeout(Math.toIntExact(timeout.toMillis())); + requestConfigBuilder.setConnectionRequestTimeout(Math.toIntExact(connectTimeout.toMillis())); } clientBuilder.setDefaultRequestConfig(requestConfigBuilder.build());