lib/rekiq/scheduler.rb in rekiq-0.8.1 vs lib/rekiq/scheduler.rb in rekiq-0.9.0

- old
+ new

@@ -1,14 +1,14 @@ module Rekiq class Scheduler - def initialize(worker_name, queue, args, job, addon, canceller_args) + def initialize(worker_name, queue, args, job, addon, cancel_args) @worker_name = worker_name @queue = queue @args = args @job = job @addon = addon - @canceller_args = canceller_args + @cancel_args = cancel_args end def schedule(from = Time.now) @work_time = @job.next_work_time(from) @@ -32,10 +32,10 @@ 'rq:job' => @job.to_array, 'rq:at' => @work_time.to_f, 'rq:schdlr' => nil }.tap do |hash| hash['rq:addon'] = @addon unless @addon.nil? - hash['rq:ca'] = @canceller_args unless @canceller_args.nil? + hash['rq:ca'] = @cancel_args unless @cancel_args.nil? end Sidekiq::Client.push(client_args) end end \ No newline at end of file