Push push a message to gate.
(_ context.Context, req *meta.PushRequest)
| 57 | |
| 58 | // Push push a message to gate. |
| 59 | func (n *Notifer) Push(_ context.Context, req *meta.PushRequest) (*meta.PushResponse, error) { |
| 60 | log.Debugf("begin push message:%v, ids:%v", req.Msg, req.ID) |
| 61 | n.broker.Push(*req.Msg, req.ID...) |
| 62 | log.Debugf("end push message:%v, ids:%v", req.Msg, req.ID) |
| 63 | |
| 64 | return &meta.PushResponse{}, nil |
| 65 | } |