diff --git a/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchTemplate.java b/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchTemplate.java index 740a6c5c5..6b94aadeb 100755 --- a/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchTemplate.java +++ b/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchTemplate.java @@ -343,5 +343,9 @@ public class ElasticsearchTemplate extends AbstractElasticsearchTemplate { } catch (Exception ignored) {} return null; } + + public Client getClient() { + return client; + } // endregion } diff --git a/src/test/java/org/springframework/data/elasticsearch/core/ElasticsearchTransportTemplateTests.java b/src/test/java/org/springframework/data/elasticsearch/core/ElasticsearchTransportTemplateTests.java index 6f3126627..401b3f19c 100644 --- a/src/test/java/org/springframework/data/elasticsearch/core/ElasticsearchTransportTemplateTests.java +++ b/src/test/java/org/springframework/data/elasticsearch/core/ElasticsearchTransportTemplateTests.java @@ -131,6 +131,13 @@ public class ElasticsearchTransportTemplateTests extends ElasticsearchTemplateTe assertThat(fetchSourceContext.excludes()).containsExactlyInAnyOrder("excl"); } + @Test // DATAES-782 + void shouldProvideClient() { + Client client = ((ElasticsearchTemplate) operations).getClient(); + + assertThat(client).isNotNull(); + } + @Data @Document(indexName = "test-index-sample-core-transport-template", replicas = 0, refreshInterval = "-1") static class SampleEntity {