}
p.rescheduler.Start()
p.readerGroup.Start()
p.checkpointTimer = time.NewTimer(backoff.Jitter(
p.options.CheckpointInterval(),
p.options.CheckpointIntervalJitterCoefficient(),
))
}
func (p *queueBase) Stop() {