Class: Sidekiq::Superworker::SubjobProcessor

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq/superworker/subjob_processor.rb

Class Method Summary collapse

Class Method Details

.original_sidekiq_item ⇒ Object 



5
 
# File 'lib/sidekiq/superworker/subjob_processor.rb', line 5

alias_method :original_sidekiq_item, :sidekiq_item

.sidekiq_item(subjob, klass, jid) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
 
# 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