private void tryConnect()

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);
    }