kanful wrote:
I also can't stop the client ...do you know what's the matter now .i want to
shutdown the client threads at once. but the class SocketConnector has no
method to close; if you have some ideas ,please help me ,thanks for any
answers;
Hi,
- creating a connection :
ConnectFuture connectFuture = mConnector.connect(this.mSocketAddress);
IoSession mIoSession = connectFuture.getSession();
- closing this connection :
mIoSession.close().awaitUninterruptibly();
Are you using "SocketConnector()" or "SocketConnector(int
processorCount, Executor executor)" ?
With the 2nd constructor you need to call executor.shutdown().
Notice that Trustin wrote :
Try to set SocketConnector.workerTimeout to smaller value (e.g. 5).
HTH,
Pierre-Louis
