10271028102910301031103210331034103510361037
STATE_DISCONNECTED_REMOTELY, null); fireConnectionStateChanged(e); } else { entry.addRegistration(selector, SelectionKey.OP_READ); } } private void dispatchMessage(TcpAddress incomingAddress, ByteBuffer byteBuffer, long bytesRead) {