Method Reply

rpc/event.go:28–42

(msg interface{})

}

func (self *RecvMsgEvent) Reply(msg interface{}) {

	data, meta, err := codec.EncodeMessage(msg, nil)

	if err != nil {
		log.Errorf("rpc reply message encode error: %s", err)
		return
	}

	self.ses.Send(&RemoteCallACK{
		MsgID:  uint32(meta.ID),
		Data:   data,
		CallID: self.callid,
	})
}