code: public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
          byte[] rpcResponse = (byte[]) e.getMessage();
          // remove marking
          Xdr x = RecordMarkingUtil.removeRecordMarking(rpcResponse);
          // remove the request from timeout manager map
          int xid = x.getXid();
          _connection.notifySender(Integer.valueOf(xid), x);
      }
docs: /*
  (non-Javadoc)
  
  @see
  org.jboss.netty.channel.SimpleChannelHandler#messageReceived(org.jboss.
  netty.channel.ChannelHandlerContext,
  org.jboss.netty.channel.MessageEvent)