class Sidekiq::Superworker::SubjobProcessor

Public Class Methods

original_sidekiq_item(subjob, klass, jid)
Alias for: sidekiq_item
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