class Sidekiq::Priority::Server::Fetch
Public Class Methods
new(options)
click to toggle source
# File lib/sidekiq/priority/server/fetch.rb, line 8 def initialize(options) queues = prioritized_queues(options[:queues]) @strictly_ordered_queues = !!options[:strict] @queues = queues.map { |q| "queue:#{q}" } @unique_queues = @queues.uniq end
Protected Instance Methods
prioritized_queues(base_queues)
click to toggle source
# File lib/sidekiq/priority/server/fetch.rb, line 17 def prioritized_queues(base_queues) queues = [] priorities = Sidekiq::Priority.priorities priorities.each do |priority| base_queues.each do |queue| queues << Sidekiq::Priority.queue_with_priority(queue, priority) end end queues end