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