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