if File.exists? Rails.root.join('config/initializers/resque.rb')
  namespace :resque do
    require Rails.root.join('config/initializers/resque.rb')
    require 'resque/tasks'
    if defined?(Resque::Scheduler)
      require 'resque_scheduler/tasks'
    end
    
    task :setup => :environment

    task :_work => ['resque:preload', 'resque:setup'] do
      work = Resque::Worker.new('*')
      Process.daemon(true)
      File.open(Rails.root.join('tmp/resque.pid'), 'w') { |f| f << work.pid }
      work.work(5)
    end

    if defined?(Resque::Scheduler)
      task :_scheduler => 'resque:setup' do
        Process.daemon(true)
        File.open(Rails.root.join('tmp/scheduler.pid'), 'w') { |f| f << Process.pid.to_s }
        Resque::Scheduler.run
      end
    end

    desc 'Start Resque daemon worker'
    task :start => 'resque:stop' do
      zfben_rails_rake_system "bash -c 'RAILS_ENV=production rake resque:_work'"
      if defined?(Resque::Scheduler)
        zfben_rails_rake_system "bash -c 'RAILS_ENV=production rake resque:_scheduler'"
      end
    end

    desc 'Stop Resque worker'
    task :stop do
      ['resque', 'scheduler'].each do |name|
        path = Rails.root.join('tmp/' + name + '.pid')
        if File.exists?(path)
          zfben_rails_rake_system "kill `cat #{path}`;rm #{path}"
        end
      end
    end

    desc 'Clear Resque data'
    task :clear do
      Resque.redis.keys('*').each{ |k| Resque.redis.del k }
    end

    desc 'Start Resque web interface'
    task :web do
      require 'resque/server'
      Resque::Server.run!
    end
  end
end