sendEof();
}
}
};
connector.setHandler(handler);
ConnectFuture future = connector.connect(address.toInetSocketAddress());
future.addListener(new IoFutureListener<ConnectFuture>() {
public void operationComplete(ConnectFuture future) {
if (future.isConnected()) {
ioSession = future.getSession();
f.setOpened();