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