@Override
            public void run() {
                try {
                    List<Object> objs = channel.getDecoder().decode(channel, message);
                    if (CollectionUtils.isNotEmpty(objs)) {
                        for (Object obj : objs) {
                            eventHandler().messageReceived(channel, obj);
                        }
                    }
                    channel.setLastReadTime(SystemClock.now());
                } catch (Exception e) {
                    eventHandler().exceptionCaught(channel, e);
                }
            }
@author Robert HG (254963746@qq.com) on 1/24/16.
lts-core/src/main/java/com/github/ltsopensource/nio/processor/AbstractNioProcessor.java