From 1fa18b5fb612ab416ecd7c4606a6c172a58080c8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?S=C3=B6ren=20Henning?= <stu114708@informatik.uni-kiel.de> Date: Mon, 25 Jul 2016 16:41:24 +0200 Subject: [PATCH] handle InvalidQueryException --- .../java/kiekpad/vizprovider/service/CassandraService.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/kiekpad/vizprovider/service/CassandraService.java b/src/main/java/kiekpad/vizprovider/service/CassandraService.java index 3f45404..53f5077 100644 --- a/src/main/java/kiekpad/vizprovider/service/CassandraService.java +++ b/src/main/java/kiekpad/vizprovider/service/CassandraService.java @@ -4,6 +4,7 @@ import org.springframework.stereotype.Service; import com.datastax.driver.core.Cluster; import com.datastax.driver.core.Session; +import com.datastax.driver.core.exceptions.InvalidQueryException; import com.datastax.driver.core.exceptions.NoHostAvailableException; @Service @@ -19,7 +20,7 @@ public class CassandraService { try { final Cluster cluster = Cluster.builder().addContactPoint(IP_ADDRESS).withPort(PORT).build(); this.session = cluster.connect(KEYSPACE); - } catch (NoHostAvailableException exception) { + } catch (NoHostAvailableException | InvalidQueryException exception) { this.session = null; } } -- GitLab