EmbeddedCassandraServerHelper.cleanEmbeddedCassandra();
throw new RuntimeException("Cannot start embedded Cassandra!", e);
}
}
private Cluster buildClusterWithConsistencyLevel(ConsistencyLevel level) {
<BUG>QueryOptions options = new QueryOptions().setConsistencyLevel(level);

return Cluster.builder().addContactPoints("localhost").withPort(CassandraTestInstance.PORT)</BUG>
.withProtocolVersion(ProtocolVersion.V3)
<BUG>.withQueryOptions(options)

.withTimestampGenerator(new AtomicMonotonicTimestampGenerator()).build();</BUG>
}

EmbeddedCassandraServerHelper.cleanEmbeddedCassandra();
throw new RuntimeException("Cannot start embedded Cassandra!", e);
}
}
private Cluster buildClusterWithConsistencyLevel(ConsistencyLevel level) {
QueryOptions queryOptions = new QueryOptions().setConsistencyLevel(level);
SocketOptions socketOptions = new SocketOptions().setConnectTimeoutMillis(CONNECT_TIMEOUT_MILLIS);
return Cluster.builder().addContactPoints("localhost").withPort(CassandraTestInstance.PORT)
.withProtocolVersion(ProtocolVersion.V3)
.withQueryOptions(queryOptions)
.withSocketOptions(socketOptions)
.withRetryPolicy(new TestRetryPolicy(3,3,3))
.withTimestampGenerator(new AtomicMonotonicTimestampGenerator()).build();
}
