JAMES-2563 Refactored query string
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/dfdc6480 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/dfdc6480 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/dfdc6480 Branch: refs/heads/master Commit: dfdc64807ccdd0d64dbb45ace430c52120dd392e Parents: 4ab1921 Author: matzepan <[email protected]> Authored: Sat Oct 20 14:14:58 2018 +0200 Committer: Benoit Tellier <[email protected]> Committed: Mon Oct 29 19:15:01 2018 +0700 ---------------------------------------------------------------------- .../james/backends/cassandra/utils/CassandraHealthCheck.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/dfdc6480/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraHealthCheck.java ---------------------------------------------------------------------- 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 b5fca40..891f099 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 @@ -37,6 +37,7 @@ public class CassandraHealthCheck implements HealthCheck { private static final Logger LOGGER = LoggerFactory.getLogger(CassandraHealthCheck.class); private static final ComponentName COMPONENT_NAME = new ComponentName("Cassandra backend"); + private static final String HEALTH_QUERY = "SELECT NOW() FROM system.local"; private Session session; @@ -55,7 +56,7 @@ public class CassandraHealthCheck implements HealthCheck { try { // execute a simple query to check if cassandra is responding // idea from: https://stackoverflow.com/questions/10246287 - session.execute("SELECT NOW() FROM system.local"); + session.execute(HEALTH_QUERY); return Result.healthy(COMPONENT_NAME); } catch (Exception e) { LOGGER.error("Error checking cassandra backend", e); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
