public void getData()

in resume-api/resume-api-cassandraql/src/main/java/org/apache/camel/example/resume/cassandra/main/ExampleDao.java [104:118]


    public void getData(Consumer<String> consumer) {
        ResultSet rs = session.execute("select * from example");

        if (rs != null) {
            Iterator<Row> iterator = rs.iterator();
            while (iterator.hasNext()) {
                Row row = iterator.next();
                String data = row.getString("text");
                LOG.trace("Retrieved data: {}", data);
                consumer.accept(data);
            }
        } else {
            LOG.warn("No records were returned");
        }
    }