(topic string, ty int64, data interface{})
| 85 | } |
| 86 | |
| 87 | func (q *QueueProtocol) notify(topic string, ty int64, data interface{}) (*queue.Message, error) { |
| 88 | client := q.client |
| 89 | msg := client.NewMessage(topic, ty, data) |
| 90 | err := client.SendTimeout(msg, false, q.option.SendTimeout) |
| 91 | if err != nil { |
| 92 | return &queue.Message{}, err |
| 93 | } |
| 94 | return msg, err |
| 95 | } |
| 96 | |
| 97 | // Notify new and send client message |
| 98 | func (q *QueueProtocol) Notify(topic string, ty int64, data interface{}) (*queue.Message, error) { |
no test coverage detected