func (rpc *PushRpc) MPushMsg(ctx context.Context, args *proto.PushMsgArg, noReply *proto.NoReply) (err error) { log.Info("rpc PushMsg :%v ", args) if args == nil { log.Errorf("rpc PushRpc() error(%v)", err) return } return }
(ctx context.Context, args *proto.PushMsgArg, SuccessReply *proto.SuccessReply)