Method addRetry

store/msg.go:117–122

(id int64)

}

func (m *messageDB) addRetry(id int64) {
	log.Debugf("id:%v", id)
	m.Lock()
	m.retry[id] = time.Now().Add(pushTimeout)
	m.Unlock()
}

func (m *messageDB) delRetry(id int64) {
	log.Debugf("id:%v", id)