First of all, let's start by making an adjustment to our CassandraConnection class. Start by importing ResultSetFuture and PreparedStatement:
import com.datastax.driver.core.ResultSetFuture;import com.datastax.driver.core.PreparedStatement;
Then we will add two new methods to allow for listenable, asynchronous operations:
public ResultSetFuture asyncOp(BoundStatement bStatement) { return session.executeAsync(bStatement);}public PreparedStatement prepare(String strCQL) { return session.prepare(strCQL);}
The asyncOp method is similar to the query method used in the last example. The difference is that the asyncOp method returns ResultSetFuture instead of ResultSet. This way, the query can be executed, and our application ...
