@@ -50,5 +50,5 @@ [o] document :thread_name scheduler option [o] unify cron_jobs#trigger_matching_jobs(now) and jobs#job_to_trigger -[ ] pluggable job queues ? +[o] pluggable job queues TODO.txt @@ -44,7 +44,7 @@ module Scheduler :every => Rufus::Scheduler::EveryJob } - def initialize + def initialize (opts) @mutex = Mutex.new @jobs = [] @@ -126,7 +126,7 @@ module Scheduler # class CronJobQueue - def initialize + def initialize (opts) @mutex = Mutex.new @jobs = {} lib/rufus/sc/jobqueues.rb @@ -104,8 +104,10 @@ module Rufus::Scheduler @options = opts - @jobs = JobQueue.new - @cron_jobs = CronJobQueue.new + @jobs = ( + opts[:job_queue_class] || Rufus::Scheduler::JobQueue).new(opts) + @cron_jobs = ( + opts[:cron_job_queue_class] || Rufus::Scheduler::CronJobQueue).new(opts) @frequency = @options[:frequency] || 0.330 end @@ -388,7 +390,7 @@ module Rufus::Scheduler 'EventMachine missing, "require \'eventmachine\'" might help' ) unless defined?(EM) - super + super(opts) end def start lib/rufus/sc/scheduler.rb 0645011143f395882b64daca1123836e09472279 John Mettraux jmettraux@gmail.com http://github.com/jmettraux/rufus-scheduler/commit/e31f619a94d3754d7c1da904a8db36c54803a248 e31f619a94d3754d7c1da904a8db36c54803a248 2009-06-16T02:38:36-07:00 2009-06-16T02:38:36-07:00 added ability to change jobqueue implementations f1f58916c9ad769cc76c9cf7cc5b280641c265d2 John Mettraux jmettraux@gmail.com