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