job/queue.go
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{},
	}
}
func NewQueue ( conf * Config , logger log . Logger , db * reform . DB , handlers HandlerMap ) Queue { l := logger . Add ( " " , " " ) return & queue { conf : conf , logger : l , db : db , handlers : handlers , subs : map [ string ] [ ] subEntry { } , } }
// NewQueue creates a new job queue.
NewQueue creates a new job queue .