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