dispatch

type Dispatch interface {
	Add(topic job.Topic, id job.ID, delay job.Delay, ttr job.TTR, body job.Body, override bool) (err error)
	Pop(topic job.Topic, blockTime time.Duration) (j *job.Job, err error)
	Finish(topic job.Topic, id job.ID) (err error)
	Delete(topic job.Topic, id job.ID) (err error)

	Run()
}