Class: Sidekiq::Superworker::SubjobProcessor
- Inherits:
-
Object
- Object
- Sidekiq::Superworker::SubjobProcessor
- 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. ? subjob.[:priority] : nil if priority queue = klass.['queue'] queue = Sidekiq::Priority.queue_with_priority(queue, priority) item['queue'] = queue end item end |