fix(elasticsearch): Connector must retry to connect to Elasticsearch …

…when receiving bad info (backport #4919) Closes gravitee-io/issues#4977
gravitee-io · Feb 2, 2021 · 3335cfe · 3335cfe
1 parent 0bb743d
commit 3335cfe
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/...-common-elasticsearch/src/main/java/io/gravitee/elasticsearch/client/http/HttpClient.java b/...-common-elasticsearch/src/main/java/io/gravitee/elasticsearch/client/http/HttpClient.java
@@ -226,7 +226,14 @@ private Single<ElasticsearchInfo> getInfo(final ElasticsearchClient client) thro
                 .get(URL_ROOT)
                 .rxSend()
                 .doOnError(throwable -> logger.error("Unable to get a connection to Elasticsearch: {}", throwable.getMessage()))
-                .map(response -> mapper.readValue(response.bodyAsString(), ElasticsearchInfo.class));
+                .map(response -> {
+                    if (response.statusCode() == HttpStatusCode.OK_200) {
+                        return mapper.readValue(response.bodyAsString(), ElasticsearchInfo.class);
+                    }
+
+                    throw new ElasticsearchException("Unable to retrieve Elasticsearch information: status[" +
+                            response.statusCode()+"] payload: [" + response.bodyAsString() + "]");
+                });
     }
 
     @Override