code: 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{},
  	}
  }
docs: // NewQueue creates a new job queue.