Class: Taskinator::Queues::SidekiqAdapter
- Inherits:
-
Object
- Object
- Taskinator::Queues::SidekiqAdapter
show all
- Defined in:
- lib/taskinator/queues/sidekiq.rb
Defined Under Namespace
Classes: JobWorker, ProcessWorker, TaskWorker
Instance Method Summary
collapse
Constructor Details
Returns a new instance of SidekiqAdapter.
11
12
13
14
15
16
17
|
# File 'lib/taskinator/queues/sidekiq.rb', line 11
def initialize(config={})
@config = {
:process_queue => :default,
:task_queue => :default,
:job_queue => :default
}.merge(config)
end
|
Instance Method Details
#enqueue_job(job) ⇒ Object
29
30
31
32
|
# File 'lib/taskinator/queues/sidekiq.rb', line 29
def enqueue_job(job)
queue = job.queue || job.job.get_sidekiq_options[:queue] || @config[:job_queue]
JobWorker.client_push('class' => JobWorker, 'args' => [job.uuid], 'queue' => queue)
end
|
#enqueue_process(process) ⇒ Object
19
20
21
22
|
# File 'lib/taskinator/queues/sidekiq.rb', line 19
def enqueue_process(process)
queue = process.queue || @config[:process_queue]
ProcessWorker.client_push('class' => ProcessWorker, 'args' => [process.uuid], 'queue' => queue)
end
|
#enqueue_task(task) ⇒ Object
24
25
26
27
|
# File 'lib/taskinator/queues/sidekiq.rb', line 24
def enqueue_task(task)
queue = task.queue || @config[:task_queue]
TaskWorker.client_push('class' => TaskWorker, 'args' => [task.uuid], 'queue' => queue)
end
|