Module: Sidekiq::PriorityQueue::TestingClient

Included in:
Client
Defined in:
lib/sidekiq/priority_queue/testing.rb

Instance Method Summary collapse

Instance Method Details

#call(worker_class, item, queue, redis_pool) ⇒ Object 



9
10
11
12
 
# File 'lib/sidekiq/priority_queue/testing.rb', line 9

def call(worker_class, item, queue, redis_pool)
  testing_verify_subqueue(item) if item['subqueue'] && !item['priority']
  yield # continue pushing the normal Sidekiq way
end

#testing_verify_subqueue(item) ⇒ Object

Help testing the lambda; raise in case it’s invalid.



15
16
17
18
19
20
21
 
# File 'lib/sidekiq/priority_queue/testing.rb', line 15

def testing_verify_subqueue(item)
  subqueue = resolve_subqueue(item['subqueue'], item['args'])
  serialized = "#{subqueue}"

  raise "subqueue shouldn't be nil" if subqueue.nil?
  raise "subqueue shouldn't be empty" if serialized == ""
end