...
Code Block | ||||
---|---|---|---|---|
| ||||
ConnectFuture cf = connector.connect(new InetSocketAddress("localhost", 8080)); // Get the close future for this session CloseFuture closeFuture = cf.getSession().getCloseFuture(); // Adding a listener to this close event closeFuture.addListener((IoFutureListener<?>) new IoFutureListener<IoFuture>() { @Override public void operationComplete(IoFuture future) { System.out.println("The session is now closed"); } }); // Do the close requesting that the pending messages are sent before // the session is closed closeFuture.getSession().close(false); // Now wait for the close to be completed closeFuture.awaitUninterruptibly(); // We can now dispose the connector connector.dispose(); {code:java} h3. How can I reconnect to server after my client session is closed.? Here is an example code: {code:java} public void sessionClosed( IoSession session ) throws Exception { // Wait for five seconds before reconnecting. Thread.sleep( 5000 ); // Reconnect. connector.connect( session.getRemoteAddress(), this ); } |
...