Class: AdvancedSneakersActiveJob::Support::LocateWorkersByQueues

Inherits:
Object
  • Object
show all
Defined in:
lib/advanced_sneakers_activejob/support/locate_workers_by_queues.rb

Instance Method Summary collapse

Constructor Details

#initialize(queues) ⇒ LocateWorkersByQueues

Returns a new instance of LocateWorkersByQueues.



6
7
8
9
10
 
# File 'lib/advanced_sneakers_activejob/support/locate_workers_by_queues.rb', line 6

def initialize(queues)
  @queues = queues.uniq.reject(&:blank?)
  @queues_without_workers = []
  @workers = []
end

Instance Method Details

#call ⇒ Object 



12
13
14
15
16
17
 
# File 'lib/advanced_sneakers_activejob/support/locate_workers_by_queues.rb', line 12

def call
  detect_workers_for_queues!
  ensure_all_workers_found!

  @workers.uniq
end