Class: Resque::FairShare::Dequeue

Inherits:
Object
  • Object
show all
Defined in:
lib/resque/fair_share/dequeue.rb

Constant Summary collapse

LEGACY_SCRIPT = 
File.read(File.expand_path('../../../lua/fair_dequeue.lua', __dir__))
SUB_QUEUE_SCRIPT = 
File.read(File.expand_path('../../../lua/fair_dequeue_v2.lua', __dir__))

Class Method Summary collapse

Class Method Details

.perform(queue) ⇒ Object 



7
8
9
10
11
12
13
14
15
 
# File 'lib/resque/fair_share/dequeue.rb', line 7

def self.perform(queue)
  config = Resque::FairShare.configuration

  if config.dequeue_strategy == :sub_queues
    perform_sub_queues(queue, config)
  else
    perform_legacy(queue, config)
  end
end