Module: Workarea::QueuesPauser

Extended by:
QueuesPauser
Included in:
QueuesPauser
Defined in:
lib/workarea/queues_pauser.rb

Instance Method Summary collapse

Instance Method Details

#pause_queues! ⇒ Object 



5
6
7
8
 
# File 'lib/workarea/queues_pauser.rb', line 5

def pause_queues!
  pauser = Sidekiq::Throttled::QueuesPauser.instance
  queues.each { |queue| pauser.pause!(queue) }
end

#queues ⇒ Object 



22
23
24
 
# File 'lib/workarea/queues_pauser.rb', line 22

def queues
  Configuration::Sidekiq.queues
end

#resume_queues! ⇒ Object 



10
11
12
13
 
# File 'lib/workarea/queues_pauser.rb', line 10

def resume_queues!
  pauser = Sidekiq::Throttled::QueuesPauser.instance
  queues.each { |queue| pauser.resume!(queue) }
end

#with_paused_queues(&block) ⇒ Object 



15
16
17
18
19
20
 
# File 'lib/workarea/queues_pauser.rb', line 15

def with_paused_queues(&block)
  pause_queues!
  yield
ensure
  resume_queues!
end