module RubyJob::Worker::ClassMethods
Public Instance Methods
jobstore()
click to toggle source
# File lib/ruby_job/worker.rb, line 44 def jobstore @jobstore || Worker.jobstore end
jobstore=(jobstore)
click to toggle source
# File lib/ruby_job/worker.rb, line 38 def jobstore=(jobstore) raise ArgumentError, 'argument provided is not a JobStore' unless jobstore.is_a?(JobStore) @jobstore = jobstore end
perform(*args)
click to toggle source
# File lib/ruby_job/worker.rb, line 48 def perform(*args) worker = new worker.send(:do_perform, *args) end
perform_async(*args)
click to toggle source
# File lib/ruby_job/worker.rb, line 53 def perform_async(*args) Job.new(worker_class_name: name, args: args).enqueue end
perform_at(at, *args)
click to toggle source
# File lib/ruby_job/worker.rb, line 57 def perform_at(at, *args) Job.new(worker_class_name: name, args: args, start_at: at).enqueue end
perform_in(in_ms, *args)
click to toggle source
# File lib/ruby_job/worker.rb, line 61 def perform_in(in_ms, *args) at = Time.now + in_ms.to_f / 1000 Job.new(worker_class_name: name, args: args, start_at: at).enqueue end