diff --git a/src/main/java/kiekpad/vizprovider/service/CassandraService.java b/src/main/java/kiekpad/vizprovider/service/CassandraService.java index 60d845a9eab43caae3c2b80eff409257889c7a95..3f454040fdef7f91a8753bf759f237a25f4b3919 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.NoHostAvailableException; @Service public class CassandraService { @@ -12,11 +13,15 @@ public class CassandraService { private static final int PORT = 32770; private static final String KEYSPACE = "demo3"; - private final Session session; + private Session session; // TODO final public CassandraService() { - final Cluster cluster = Cluster.builder().addContactPoint(IP_ADDRESS).withPort(PORT).build(); - this.session = cluster.connect(KEYSPACE); + try { + final Cluster cluster = Cluster.builder().addContactPoint(IP_ADDRESS).withPort(PORT).build(); + this.session = cluster.connect(KEYSPACE); + } catch (NoHostAvailableException exception) { + this.session = null; + } } public Session getSession() {