Contents

module Qless
  module JobReservers
    class Ordered
      attr_reader :queues

      def initialize(queues)
        @queues = queues
      end

      def reserve
        @queues.each do |q|
          job = q.pop
          return job if job
        end
        nil
      end

      def description
        @description ||= @queues.map(&:name).join(', ') + " (ordered)"
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
qless-0.9.3	lib/qless/job_reservers/ordered.rb
qless-0.9.2	lib/qless/job_reservers/ordered.rb
qless-0.9.1	lib/qless/job_reservers/ordered.rb