Function NewWorker

job/queue.go:49–54

NewWorker makes new working process

(queue *Queue)

//NewWorker makes new working process
func NewWorker(queue *Queue) *Worker {
	return &Worker{
		queue:   queue,
		CloseCh: make(chan bool),
	}
}

//Start consuming task
func (worker *Worker) Start() {