Contents

module Resque
  module Integration
    module Extensions
      module Worker
        def queues
          queues = super
          shuffle? ? queues.shuffle : queues
        end

        def shuffle?
          return @shuffle if defined?(@shuffle)
          @shuffle = !ENV['SHUFFLE'].to_s.empty?
        end
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
resque-integration-3.8.2	lib/resque/integration/extensions/worker.rb
resque-integration-3.8.1	lib/resque/integration/extensions/worker.rb
resque-integration-3.8.0	lib/resque/integration/extensions/worker.rb
resque-integration-3.7.1	lib/resque/integration/extensions/worker.rb
resque-integration-3.5.1	lib/resque/integration/extensions/worker.rb
resque-integration-3.5.0	lib/resque/integration/extensions/worker.rb
resque-integration-3.4.1	lib/resque/integration/extensions/worker.rb