@Override
        public void run() {
            try {
                AbstractRemotingProcessor.this.doProcess(ctx, msg);
            } catch (Throwable e) {
                //protect the thread running this task
                String remotingAddress = RemotingUtil.parseRemoteAddress(ctx.getChannelContext()
                    .channel());
                logger
                    .error(
                        "Exception caught when process rpc request command in AbstractRemotingProcessor, Id="
                                + msg.getId() + "! Invoke source address is [" + remotingAddress
                                + "].", e);
            }
        }
Task for asynchronous process.

@author jiangping
@version $Id: RemotingProcessor.java, v 0.1 2015-10-14 PM7:40:44 tao Exp $
src/main/java/com/alipay/remoting/AbstractRemotingProcessor.java