class Taskinator::Queues::ResqueAdapter
Public Class Methods
new(config={})
click to toggle source
# File lib/taskinator/queues/resque.rb, line 11 def initialize(config={}) config = Taskinator::Queues::DefaultConfig.merge(config) CreateProcessWorker.class_eval do @queue = config[:definition_queue] end ProcessWorker.class_eval do @queue = config[:process_queue] end TaskWorker.class_eval do @queue = config[:task_queue] end end
Public Instance Methods
enqueue_create_process(definition, uuid, args)
click to toggle source
# File lib/taskinator/queues/resque.rb, line 28 def enqueue_create_process(definition, uuid, args) queue = definition.queue || Resque.queue_from_class(CreateProcessWorker) Resque.enqueue_to(queue, CreateProcessWorker, definition.name, uuid, Taskinator::Persistence.serialize(args)) end
enqueue_process(process)
click to toggle source
# File lib/taskinator/queues/resque.rb, line 33 def enqueue_process(process) queue = process.queue || Resque.queue_from_class(ProcessWorker) Resque.enqueue_to(queue, ProcessWorker, process.uuid) end
enqueue_task(task)
click to toggle source
# File lib/taskinator/queues/resque.rb, line 38 def enqueue_task(task) queue = task.queue || Resque.queue_from_class(TaskWorker) Resque.enqueue_to(queue, TaskWorker, task.uuid) end