func (q *queue) Retry(wb *leveldb.Batch, qp queuePair, delay time.Duration) error {
	wb.Delete(activeQueueKey(qp.key))
	if err := q.Add(wb, qp.URL, qp.Depth, time.Now().Add(delay)); err != nil {
		return err
	}
	atomic.AddInt32(&q.numActive, -1)
	return nil
}
// Retry processing this item at a later time.
Retry processing this item at a later time.
// Retry processing this item at a later time .
func (q *queue) Retry(wb *leveldb.Batch, qp queuePair, delay time.Duration) error {
	wb.Delete(activeQueueKey(qp.key))
	if err := q.Add(wb, qp.URL, qp.Depth, time.Now().Add(delay)); err != nil {
		return err
	}
	atomic.AddInt32(&q.numActive, -1)
	return nil
}
func ( q * queue ) Retry ( wb * leveldb . Batch , qp queuePair , delay time . Duration ) error { wb . Delete ( activeQueueKey ( qp . key ) ) if err := q . Add ( wb , qp . URL , qp . Depth , time . Now ( ) . Add ( delay ) ) ; err != nil { return err } atomic . AddInt32 ( & q . numActive , - 1 ) return nil }
Retry processing this item at a later time.
Retry processing this item at a later time .