class Taskinator::Queues::SidekiqAdapter
Public Class Methods
new(config={})
click to toggle source
# File lib/taskinator/queues/sidekiq.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/sidekiq.rb, line 15 def enqueue_create_process(definition, uuid, args) queue = definition.queue || @config[:definition_queue] CreateProcessWorker.client_push('class' => CreateProcessWorker, 'args' => [definition.name, uuid, Taskinator::Persistence.serialize(args)], 'queue' => queue) end
enqueue_process(process)
click to toggle source
# File lib/taskinator/queues/sidekiq.rb, line 20 def enqueue_process(process) queue = process.queue || @config[:process_queue] TaskWorker.client_push('class' => ProcessWorker, 'args' => [process.uuid], 'queue' => queue) end
enqueue_task(task)
click to toggle source
# File lib/taskinator/queues/sidekiq.rb, line 25 def enqueue_task(task) queue = task.queue || @config[:task_queue] TaskWorker.client_push('class' => TaskWorker, 'args' => [task.uuid], 'queue' => queue) end