Skip to content

Commit 771d9c6

Browse files
committed
adds configuration
1 parent 6466d64 commit 771d9c6

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

elasticsearch-driver/src/main/java/org/jnosql/diana/elasticsearch/document/ElasticsearchDocumentConfiguration.java

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -50,12 +50,15 @@ public class ElasticsearchDocumentConfiguration implements UnaryDocumentConfigur
5050

5151
private List<Header> headers = new ArrayList<>();
5252

53-
private int maxRetryTimoutMillis = 0;
53+
private int maxRetryTimoutMillis = RestClientBuilder.DEFAULT_MAX_RETRY_TIMEOUT_MILLIS;
5454

5555
public ElasticsearchDocumentConfiguration() {
5656

5757
Map<String, String> configurations = ConfigurationReader.from(FILE_CONFIGURATION);
58-
58+
String maxRetry = configurations.get("elasticsearch-maxRetryTimeoutMillis");
59+
if (maxRetry != null) {
60+
maxRetryTimoutMillis = Integer.valueOf(maxRetry);
61+
}
5962
if (configurations.isEmpty()) {
6063
return;
6164
}
@@ -110,8 +113,12 @@ public ElasticsearchDocumentCollectionManagerFactory get(Settings settings) thro
110113
RestClientBuilder builder = RestClient.builder(httpHosts.toArray(new HttpHost[httpHosts.size()]));
111114
builder.setDefaultHeaders(headers.stream().toArray(Header[]::new));
112115

116+
String maxRetry = configurations.get("elasticsearch-maxRetryTimeoutMillis");
117+
if (maxRetry != null) {
118+
maxRetryTimoutMillis = Integer.valueOf(maxRetry);
119+
}
120+
113121
builder.setMaxRetryTimeoutMillis(maxRetryTimoutMillis);
114-
builder.set
115122
RestHighLevelClient client = new RestHighLevelClient(builder);
116123
return new ElasticsearchDocumentCollectionManagerFactory(client);
117124
}

0 commit comments

Comments
 (0)