From 3afd6fd4279722846a4f665db3e0c82482d97518 Mon Sep 17 00:00:00 2001 From: Peter-Josef Meisch Date: Sat, 4 Apr 2020 19:19:26 +0200 Subject: [PATCH] DATAES-782 - Make underlying TransportClient accessible. Original PR: #421 --- .../data/elasticsearch/core/ElasticsearchTemplate.java | 4 ++++ .../core/ElasticsearchTransportTemplateTests.java | 7 +++++++ 2 files changed, 11 insertions(+) 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 {