class Sidekiq::CustomQueue::ClientMiddleware

Public Instance Methods

call(worker_class, msg, queue, _redis_pool) { || ... } click to toggle source
# File lib/sidekiq/custom_queue/client_middleware.rb, line 4
def call(worker_class, msg, queue, _redis_pool)
  worker = worker_class.constantize
  queue.replace(worker.custom_queue(msg).to_s) if worker.respond_to?(:custom_queue)
  yield
end