class Sidekiq::Superworker::SubjobProcessor
Public Class Methods
sidekiq_item(subjob, klass, jid)
click to toggle source
# File lib/sidekiq/superworker/subjob_processor.rb, line 7 def sidekiq_item(subjob, klass, jid) item = original_sidekiq_item(subjob, klass, jid) # Modify the queue to be the prioritized queue, if necessary priority = subjob.meta ? subjob.meta[:priority] : nil if priority queue = klass.get_sidekiq_options['queue'] queue = Sidekiq::Priority.queue_with_priority(queue, priority) item['queue'] = queue end item end
Also aliased as: original_sidekiq_item