向未发送队列中添加记录
(id int64)
| 130 | |
| 131 | // 向未发送队列中添加记录 |
| 132 | func (m *messageDB) addQueue(id int64) error { |
| 133 | log.Debugf("id:%v", id) |
| 134 | key := util.EncodeInt64(id) |
| 135 | |
| 136 | m.addRetry(id) |
| 137 | return m.queue.Put(key, []byte(""), nil) |
| 138 | } |
| 139 | |
| 140 | func (m *messageDB) send(pm meta.PushMessage) error { |
| 141 | buf, err := json.Marshal(pm) |