issues/2334 | sample spring elastic app

* clean up
* improvements

Signed-off-by: Snoopy009 <[email protected]>

Author: Yordaniss

spring-elastic/src/main/java/com/example/spring_elastic/client/BookElasticsearchClient.java

@@ -10,14 +10,16 @@
 import co.elastic.clients.transport.ElasticsearchTransport;
 import co.elastic.clients.transport.rest_client.RestClientTransport;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
 
+@Component
 public class BookElasticsearchClient {
     private ElasticsearchClient client;
 
     @Value("${spring.elasticsearch.port}")
-    private Integer port;
+    private String port;
 
-    @Value("${spring.elasticsearch.port}")
+    @Value("${spring.elasticsearch.url}")
     private String url;
 
     public ElasticsearchClient getClient()
@@ -31,7 +33,7 @@ public ElasticsearchClient getClient()
 
     private void initClient()
     {
-        RestClient restClient = RestClient.builder(new HttpHost("localhost", 9200)).build();
+        RestClient restClient = RestClient.builder(new HttpHost(url, Integer.parseInt(port))).build();
 
         ElasticsearchTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());
 

spring-elastic/src/main/java/com/example/spring_elastic/service/BookElasticsearchService.java

@@ -6,18 +6,18 @@
 
 import com.example.spring_elastic.client.BookElasticsearchClient;
 import com.example.spring_elastic.models.Book;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Configuration;
 
 
 import co.elastic.clients.elasticsearch._types.ElasticsearchException;
-import co.elastic.clients.elasticsearch.core.BulkRequest;
 import co.elastic.clients.elasticsearch.core.SearchResponse;
 import co.elastic.clients.elasticsearch.core.search.Hit;
 
 @Configuration
 public class BookElasticsearchService {
-    BookElasticsearchClient client = new BookElasticsearchClient();
-
+    @Autowired
+    private BookElasticsearchClient client;
     private static final String BOOK_INDEX = "books";
 
     public Book createBook(Book book) {