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

Reply via email to