List<ListenableFuture<OperationResult<Void>>> futures = Lists.newArrayList();
WriteAheadEntry walEntry;
while (null != (walEntry = wal.readNextEntry()) && count-- > 0) {
MutationBatch m = keyspace.prepareMutationBatch();
try {
walEntry.readMutation(m);
futures.add(executeWalEntry(walEntry, m));
}
catch (WalException e) {
wal.removeEntry(walEntry);
}