Method: Worker::Queue#enqueue

Defined in:
lib/worker/queue.rb

#enqueue(job) ⇒ Object



77
78
79
80
81
82
83
84
85
# File 'lib/worker/queue.rb', line 77

def enqueue(job)
  db[:worker_jobs].insert(
      job_class: job.class.name,
      queue: job.queue,
      priority: job.priority,
      handler: job.serialize,
      run_at: job.run_at,
  )
end