class Taskinator::Queues::DelayedJobAdapter

Constants

CreateProcessWorker
ProcessWorker
TaskWorker

Public Class Methods

new(config={}) click to toggle source
# File lib/taskinator/queues/delayed_job.rb, line 11
def initialize(config={})
  @config = Taskinator::Queues::DefaultConfig.merge(config)
end

Public Instance Methods

enqueue_create_process(definition, uuid, args) click to toggle source
# File lib/taskinator/queues/delayed_job.rb, line 15
def enqueue_create_process(definition, uuid, args)
  queue = definition.queue || @config[:definition_queue]
  ::Delayed::Job.enqueue CreateProcessWorker.new(definition.name, uuid, Taskinator::Persistence.serialize(args)), :queue => queue
end
enqueue_process(process) click to toggle source
# File lib/taskinator/queues/delayed_job.rb, line 20
def enqueue_process(process)
  queue = process.queue || @config[:process_queue]
  ::Delayed::Job.enqueue ProcessWorker.new(process.uuid), :queue => queue
end
enqueue_task(task) click to toggle source
# File lib/taskinator/queues/delayed_job.rb, line 25
def enqueue_task(task)
  queue = task.queue || @config[:task_queue]
  ::Delayed::Job.enqueue TaskWorker.new(task.uuid), :queue => queue
end