I still have those problems with latest packages. For the exception I'm seeing, last time I had one of those I solved it with:
public void flushAndClose() {
IoFutureListener<IoFuture> listener = new
IoFutureListener<IoFuture>() {
@Override
public void operationComplete(IoFuture future) {
future.getSession().close(true);
}
};
lastFuture.addListener(listener);
}
