This is an automated email from the ASF dual-hosted git repository. btellier pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit f5b2483c3895c648e15bff319eb53b406d071bb2 Author: Benoit Tellier <btell...@linagora.com> AuthorDate: Fri Apr 24 09:53:39 2020 +0700 JAMES-3065 s/HealthCheck::checkReactive/HealthCheck::check/ --- .../james/backends/cassandra/utils/CassandraHealthCheck.java | 2 +- .../james/backends/cassandra/utils/CassandraHealthCheckTest.java | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraHealthCheck.java b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraHealthCheck.java index c502d57..07f575b 100644 --- a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraHealthCheck.java +++ b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraHealthCheck.java @@ -51,7 +51,7 @@ public class CassandraHealthCheck implements HealthCheck { } @Override - public Mono<Result> checkReactive() { + public Mono<Result> check() { // execute a simple query to check if cassandra is responding // idea from: https://stackoverflow.com/questions/10246287 return queryExecutor.execute(SAMPLE_QUERY) 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 1796033..dbe115e 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 @@ -49,7 +49,7 @@ class CassandraHealthCheckTest { @Test void checkShouldReturnHealthyWhenCassandraIsRunning() { - Result check = healthCheck.checkReactive().block(); + Result check = healthCheck.check().block(); assertThat(check.isHealthy()).isTrue(); } @@ -58,7 +58,7 @@ class CassandraHealthCheckTest { void checkShouldReturnUnhealthyWhenCassandraIsNotRunning(DockerCassandraExtension.DockerCassandra cassandraServer) { try { cassandraServer.getContainer().pause(); - Result check = healthCheck.checkReactive().block(); + Result check = healthCheck.check().block(); assertThat(check.isUnHealthy()).isTrue(); } finally { @@ -72,12 +72,12 @@ class CassandraHealthCheckTest { try { cassandraServer.getContainer().pause(); - healthCheck.checkReactive().block(); + healthCheck.check().block(); } finally { cassandraServer.getContainer().unpause(); } - Result check = healthCheck.checkReactive().block(); + Result check = healthCheck.check().block(); assertThat(check.isHealthy()).isTrue(); } --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org