@@ -33,7 +33,7 @@ module Scheduler # A reference to the scheduler owning this job # - attr_reader :scheduler + attr_accessor :scheduler # The initial, raw, scheduling info (at / in / every / cron) # lib/rufus/sc/jobs.rb @@ -252,11 +252,15 @@ module Rufus::Scheduler # def get_queue (type, opts) - if type == :cron + q = if type == :cron opts[:cron_job_queue] || Rufus::Scheduler::CronJobQueue.new else opts[:job_queue] || Rufus::Scheduler::JobQueue.new end + + q.scheduler = self if q.respond_to?(:scheduler=) + + q end def combine_opts (schedulable, opts) lib/rufus/sc/scheduler.rb 2567d1cd205424e4359d342176c1c0725826e710 John Mettraux jmettraux@gmail.com http://github.com/jmettraux/rufus-scheduler/commit/1733339a227c122955bbeadbae78395c51d05ee4 1733339a227c122955bbeadbae78395c51d05ee4 2009-06-26T03:11:24-07:00 2009-06-26T03:11:24-07:00 keeping a reference to the scheduler in the jobqueues (if necessary) 496a6c0bbfd0081e5fe6ac1468de72e17892921e John Mettraux jmettraux@gmail.com