func NewQueue(conf *Config, logger log.Logger, db *reform.DB,
	handlers HandlerMap) Queue {
	l := logger.Add("type", "job.Queue")
	return &queue{
		conf:     conf,
		logger:   l,
		db:       db,
		handlers: handlers,
		subs:     map[string][]subEntry{},
	}
}
func NewQueue(conf *Config, logger log.Logger, db *reform.DB,
	handlers HandlerMap) Queue {
	l := logger.Add("type", "job.Queue")
	return &queue{
		conf:     conf,
		logger:   l,
		db:       db,
		handlers: handlers,
		subs:     map[string][]subEntry{},
	}
}
// NewQueue creates a new job queue.