diff --git a/oak-search-elastic/src/test/java/org/apache/jackrabbit/oak/plugins/index/elastic/ElasticConnectionRule.java b/oak-search-elastic/src/test/java/org/apache/jackrabbit/oak/plugins/index/elastic/ElasticConnectionRule.java index d915493bc9b..9bb4cf022d1 100644 --- a/oak-search-elastic/src/test/java/org/apache/jackrabbit/oak/plugins/index/elastic/ElasticConnectionRule.java +++ b/oak-search-elastic/src/test/java/org/apache/jackrabbit/oak/plugins/index/elastic/ElasticConnectionRule.java @@ -16,6 +16,7 @@ */ package org.apache.jackrabbit.oak.plugins.index.elastic; +import org.apache.commons.io.IOUtils; import org.apache.commons.lang3.RandomStringUtils; import org.junit.rules.ExternalResource; import org.junit.runner.Description; @@ -74,10 +75,11 @@ protected void after() { ElasticConnection esConnection = getElasticConnection(); if (esConnection != null) { try { - esConnection.getClient().indices().delete(d->d.index(esConnection.getIndexPrefix() + "*")); - esConnection.close(); + esConnection.getClient().indices().delete(d -> d.index(this.indexPrefix + "*")); } catch (IOException e) { - LOG.error("Unable to delete indexes with prefix {}", esConnection.getIndexPrefix()); + LOG.error("Unable to delete indexes with prefix {}", this.indexPrefix); + } finally { + IOUtils.closeQuietly(esConnection, e -> LOG.debug("Error closing Elasticsearch connection", e)); } } }