Contents

task "resque:fifo-worker" => [ "resque:preload", "resque:setup" ] do
  require 'resque'
  require 'resque/fifo/queue'

  prefix = ENV['PREFIX'] || 'fifo'
  worker = Resque::Plugins::Fifo::Worker.new
  worker.prepare
  worker.log "Starting worker #{self}"
  worker.work(ENV['INTERVAL'] || 5) # interval, will block
end

task "resque:fifo-workers" do
  threads = []

  if ENV['COUNT'].to_i < 1
    abort "set COUNT env var, e.g. $ COUNT=2 rake resque:workers"
  end

  ENV['COUNT'].to_i.times do
    threads << Thread.new do
      system "rake resque:fifo-worker"
    end
  end

  threads.each { |thread| thread.join }
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
resque-fifo-queue-0.1.2	lib/resque/fifo/tasks.rb