Method delRetry

store/msg.go:124–129

(id int64)

}

func (m *messageDB) delRetry(id int64) {
	log.Debugf("id:%v", id)
	m.Lock()
	delete(m.retry, id)
	m.Unlock()
}

// 向未发送队列中添加记录
func (m *messageDB) addQueue(id int64) error {