diff --git a/spring-boot-project/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/cassandra/CassandraHealthIndicator.java b/spring-boot-project/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/cassandra/CassandraHealthIndicator.java index 9b57d2eec9f9..31ed6ce78509 100644 --- a/spring-boot-project/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/cassandra/CassandraHealthIndicator.java +++ b/spring-boot-project/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/cassandra/CassandraHealthIndicator.java @@ -16,6 +16,7 @@ package org.springframework.boot.actuate.cassandra; +import com.datastax.oss.driver.api.core.ConsistencyLevel; import com.datastax.oss.driver.api.core.cql.ResultSet; import com.datastax.oss.driver.api.core.cql.SimpleStatement; @@ -34,6 +35,9 @@ */ public class CassandraHealthIndicator extends AbstractHealthIndicator { + private static final SimpleStatement SELECT = SimpleStatement + .newInstance("SELECT release_version FROM system.local").setConsistencyLevel(ConsistencyLevel.LOCAL_ONE); + private CassandraOperations cassandraOperations; public CassandraHealthIndicator() { @@ -52,8 +56,7 @@ public CassandraHealthIndicator(CassandraOperations cassandraOperations) { @Override protected void doHealthCheck(Health.Builder builder) throws Exception { - SimpleStatement select = SimpleStatement.newInstance("SELECT release_version FROM system.local"); - ResultSet results = this.cassandraOperations.getCqlOperations().queryForResultSet(select); + ResultSet results = this.cassandraOperations.getCqlOperations().queryForResultSet(SELECT); if (results.isFullyFetched()) { builder.up(); return;