Close the underlying ES client

Signed-off-by: Elbert Evangelista <elbert.evangelista@eurotech.com>
eclipse · Jun 27, 2022 · 18f43bb · 18f43bb
1 parent ed4bc3c
commit 18f43bb
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/...main/java/org/eclipse/kapua/service/elasticsearch/client/AbstractElasticsearchClient.java b/...main/java/org/eclipse/kapua/service/elasticsearch/client/AbstractElasticsearchClient.java
@@ -25,7 +25,7 @@ public abstract class AbstractElasticsearchClient<C extends Closeable> implement
 
     protected String clientType;
 
-    private C client;
+    protected C client;
 
     private ElasticsearchClientConfiguration clientConfiguration;
     private ModelContext modelContext;

diff --git a/...ain/java/org/eclipse/kapua/service/elasticsearch/client/rest/RestElasticsearchClient.java b/...ain/java/org/eclipse/kapua/service/elasticsearch/client/rest/RestElasticsearchClient.java
@@ -118,7 +118,13 @@ public void init() throws ClientInitializationException {
 
     @Override
     public void close() {
-        // No resources to close
+        if(client != null) {
+            try {
+                client.close();
+            } catch (IOException e) {
+                LOG.error("Error closing client", e);
+            }
+        }
     }
 
     @Override