Skip to content

Commit

Permalink
RIP Merb
Browse files Browse the repository at this point in the history
  • Loading branch information
bkeepers committed Sep 4, 2010
1 parent 50d0d80 commit 962afc5
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 13 deletions.
8 changes: 2 additions & 6 deletions lib/delayed/tasks.rb
Original file line number Diff line number Diff line change
@@ -1,15 +1,11 @@
# Re-definitions are appended to existing tasks
task :environment
task :merb_env

namespace :jobs do
desc "Clear the delayed_job queue."
task :clear => [:merb_env, :environment] do
task :clear => :environment do
Delayed::Job.delete_all
end

desc "Start a delayed_job worker."
task :work => [:merb_env, :environment] do
task :work => :environment do
Delayed::Worker.new(:min_priority => ENV['MIN_PRIORITY'], :max_priority => ENV['MAX_PRIORITY']).start
end
end
4 changes: 1 addition & 3 deletions lib/delayed/worker.rb
Original file line number Diff line number Diff line change
Expand Up @@ -16,9 +16,7 @@ class Worker
cattr_accessor :destroy_failed_jobs
self.destroy_failed_jobs = true

self.logger = if defined?(Merb::Logger)
Merb.logger
elsif defined?(Rails)
self.logger = if defined?(Rails)
Rails.logger
elsif defined?(RAILS_DEFAULT_LOGGER)
RAILS_DEFAULT_LOGGER
Expand Down
4 changes: 0 additions & 4 deletions lib/delayed_job.rb
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,3 @@

Object.send(:include, Delayed::MessageSending)
Module.send(:include, Delayed::MessageSending::ClassMethods)

if defined?(Merb::Plugins)
Merb::Plugins.add_rakefiles File.dirname(__FILE__) / 'delayed' / 'tasks'
end

0 comments on commit 962afc5

Please sign in to comment.