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