code: func (server *Server) NewCustomQueueWorker(consumerTag string, concurrency int, queue string) *Worker {
  	return &Worker{
  		server:      server,
  		ConsumerTag: consumerTag,
  		Concurrency: concurrency,
  		Queue:       queue,
  	}
  }
docs: // NewCustomQueueWorker creates Worker instance with Custom Queue