class Resque::Plugins::Fifo::Worker

# File lib/resque/plugins/fifo/worker.rb, line 10
def queues=(queues)
  queues = queues.empty? ? (ENV["QUEUES"] || ENV['QUEUE']).to_s.split(',') : queues
  @main_queue_name = "#{manager.queue_prefix}-#{SecureRandom.hex(10)}"

  @queues = ([:fifo_refresh, main_queue_name] + queues).map { |queue| queue.to_s.strip }
  unless ['*', '?', '{', '}', '[', ']'].any? { |char| @queues.join.include?(char) }
    @static_queues = @queues.flatten.uniq
  end
  validate_queues
end

# File lib/resque/plugins/fifo/worker.rb, line 51
def register_worker
  super

  puts "Fifo Startup - Updating worker list"
  manager.request_refresh
end

# File lib/resque/plugins/fifo/worker.rb, line 23
def reserve
  queues.each do |queue|
    log_with_severity :debug, "Checking #{queue}"
    if job = Resque.reserve(queue)
      log_with_severity :debug, "Found job on #{queue}"

      if job.payload['enqueue_ts']
        delay_ts = Time.now.to_i - job.payload['enqueue_ts'].to_i
        max_delay = Resque.redis.get("fifo-stats-max-delay") || 0
        Resque.redis.incrby("fifo-stats-accumulated-delay", delay_ts)
        Resque.redis.incr("fifo-stats-accumulated-count")
        if (delay_ts > max_delay.to_i)
          Resque.redis.set("fifo-stats-max-delay", max_delay)
        end
      end
      return job
    end
  end

  nil
rescue Exception => e
  log_with_severity :error, "Error reserving job: #{e.inspect}"
  log_with_severity :error, e.backtrace.join("\n")
  raise e
end

# File lib/resque/plugins/fifo/worker.rb, line 58
def unregister_worker(exception = nil)
  super(exception)

  puts "Fifo Shutdown - Updating worker list"
  manager.request_refresh
end

# File lib/resque/plugins/fifo/worker.rb, line 67
def manager
  @manager ||=  Resque::Plugins::Fifo::Queue::Manager.new
end