module Sidekiq::PriorityQueue::TestingClient

Public Instance Methods

call(worker_class, item, queue, redis_pool) { || ... } click to toggle source
# 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) click to toggle source

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

# 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