Class: Taskinator::Queues::SidekiqAdapter
- Inherits:
-
Object
- Object
- Taskinator::Queues::SidekiqAdapter
show all
- Defined in:
- lib/taskinator/queues/sidekiq.rb
Defined Under Namespace
Classes: CreateProcessWorker, ProcessWorker, TaskWorker
Instance Method Summary
collapse
Constructor Details
Returns a new instance of SidekiqAdapter.
11
12
13
|
# File 'lib/taskinator/queues/sidekiq.rb', line 11
def initialize(config={})
@config = Taskinator::Queues::DefaultConfig.merge(config)
end
|
Instance Method Details
#enqueue_create_process(definition, uuid, args) ⇒ Object
#enqueue_process(process) ⇒ Object
20
21
22
23
|
# 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) ⇒ Object
25
26
27
28
|
# 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
|