in resume-api/resume-api-cassandraql/src/main/java/org/apache/camel/example/resume/cassandra/main/CassandraClient.java [38:65]
private void tryConnect(String host, int port) {
InetSocketAddress socketAddress = new InetSocketAddress(host, port);
int i = 12;
do {
try {
LOG.info("Trying to connect to: {}:{}", host, port);
session = CqlSession.builder()
.addContactPoint(socketAddress)
.withLocalDatacenter("datacenter1")
.build();
return;
} catch (Exception e) {
LOG.error("Failed to connect: {}", e.getMessage());
i--;
if (i == 0) {
throw e;
}
try {
Thread.sleep(10000);
} catch (InterruptedException ex) {
return;
}
}
} while (i > 0);
}