lib/active_job/cancel.rb in activejob-cancel-0.3.0 vs lib/active_job/cancel.rb in activejob-cancel-0.3.1
- old
+ new
@@ -19,18 +19,18 @@
end
module ClassMethods
def cancel(job_id)
if can_cancel?
- cancel_adapter_class.new.cancel(job_id, self.queue_name)
+ cancel_adapter_class.new.cancel(job_id, self.new.queue_name)
else
raise NotImplementedError, 'This queueing backend does not support cancel.'
end
end
def cancel_by(opts)
if can_cancel?
- cancel_adapter_class.new.cancel_by(opts, self.queue_name)
+ cancel_adapter_class.new.cancel_by(opts, self.new.queue_name)
else
raise NotImplementedError, 'This queueing backend does not support cancel_by.'
end
end