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