@Override
    public void messageReceived(IoSession session, Object buf) {
        final IoSessionInputStream in = (IoSessionInputStream) session
                .getAttribute(KEY_IN);
        in.write((IoBuffer) buf);
    }
@ Override public void messageReceived ( IoSession session , Object buf ) { final IoSessionInputStream in = ( IoSessionInputStream ) session . getAttribute ( KEY_IN ) ; in . write ( ( IoBuffer ) buf ) ; }
Forwards read data to input stream.