Contents

namespace :qu do
  desc "Start a worker"
  task :work  => :environment do
    queues = (ENV['QUEUES'] || ENV['QUEUE'] || 'default').to_s.split(',')
    Qu::Worker.new(*queues).start
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
qu-0.1.0	lib/qu/tasks.rb