This is an automated email from the ASF dual-hosted git repository. rouazana pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 1b133c9ea8e8c3a23905fc91ad9a4e9f56a31e30 Author: Matthieu Baechler <[email protected]> AuthorDate: Thu Jul 25 12:03:47 2019 +0200 JAMES-2848 plug a cassandra cluster leak --- .../james/backends/cassandra/utils/CassandraHealthCheckTest.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/utils/CassandraHealthCheckTest.java b/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/utils/CassandraHealthCheckTest.java index edff790..3a77ce7 100644 --- a/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/utils/CassandraHealthCheckTest.java +++ b/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/utils/CassandraHealthCheckTest.java @@ -25,6 +25,7 @@ import org.apache.james.backends.cassandra.CassandraCluster; import org.apache.james.backends.cassandra.DockerCassandraExtension; import org.apache.james.backends.cassandra.components.CassandraModule; import org.apache.james.core.healthcheck.Result; +import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; @@ -33,13 +34,19 @@ import org.junit.jupiter.api.extension.ExtendWith; public class CassandraHealthCheckTest { private CassandraHealthCheck healthCheck; + private CassandraCluster cassandra; @BeforeEach void setUp(DockerCassandraExtension.DockerCassandra cassandraServer) { - CassandraCluster cassandra = CassandraCluster.create(CassandraModule.builder().build(), cassandraServer.getHost()); + cassandra = CassandraCluster.create(CassandraModule.builder().build(), cassandraServer.getHost()); healthCheck = new CassandraHealthCheck(cassandra.getConf()); } + @AfterEach + void tearDown() { + cassandra.close(); + } + @Test void checkShouldReturnHealthyWhenCassandraIsRunning() { Result check = healthCheck.check(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
