You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by ro...@apache.org on 2019/07/26 07:51:27 UTC
[james-project] 08/32: JAMES-2848 plug a cassandra cluster leak
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 <ma...@apache.org>
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: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org