Class: Sidekiq::Simulator

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq/simulator.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(queue) ⇒ Simulator

Returns a new instance of Simulator.



12
13
14
15
 
# File 'lib/sidekiq/simulator.rb', line 12

def initialize(queue)
  @queues = [queue].flatten.uniq
  @launcher = Sidekiq::Launcher.new(sidekiq_options(queues))
end

Instance Attribute Details

#launcher ⇒ Object (readonly)

Returns the value of attribute launcher.



6
7
8
 
# File 'lib/sidekiq/simulator.rb', line 6

def launcher
  @launcher
end

#queues ⇒ Object (readonly)

Returns the value of attribute queues.



6
7
8
 
# File 'lib/sidekiq/simulator.rb', line 6

def queues
  @queues
end

Class Method Details

.process_queue(queue) ⇒ Object 



8
9
10
 
# File 'lib/sidekiq/simulator.rb', line 8

def self.process_queue(queue)
  new(queue).process_queue { yield }
end

Instance Method Details

#process_queue ⇒ Object 



17
18
19
20
21
 
# File 'lib/sidekiq/simulator.rb', line 17

def process_queue
  run_launcher { yield }
ensure
  terminate_launcher
end