Class: Sidekiq::Priority::Server::Fetch

Inherits:
BasicFetch
  • Object
show all
Defined in:
lib/sidekiq/priority/server/fetch.rb

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ Fetch

Returns a new instance of Fetch.



7
8
9
10
11
12
# File 'lib/sidekiq/priority/server/fetch.rb', line 7

def initialize(options)
  queues = prioritized_queues(options[:queues])
  @strictly_ordered_queues = !!options[:strict]
  @queues = queues.map { |q| "queue:#{q}" }
  @unique_queues = @queues.uniq
end