Class: Taskinator::Queues::DelayedJobAdapter
- Inherits:
-
Object
- Object
- Taskinator::Queues::DelayedJobAdapter
- Defined in:
- lib/taskinator/queues/delayed_job.rb
Defined Under Namespace
Classes: ProcessWorker, TaskWorker
Instance Method Summary collapse
- #enqueue_process(process) ⇒ Object
- #enqueue_task(task) ⇒ Object
-
#initialize(config = {}) ⇒ DelayedJobAdapter
constructor
A new instance of DelayedJobAdapter.
Constructor Details
#initialize(config = {}) ⇒ DelayedJobAdapter
Returns a new instance of DelayedJobAdapter.
11 12 13 14 15 16 |
# File 'lib/taskinator/queues/delayed_job.rb', line 11 def initialize(config={}) @config = { :process_queue => :default, :task_queue => :default }.merge(config) end |
Instance Method Details
#enqueue_process(process) ⇒ Object
18 19 20 |
# File 'lib/taskinator/queues/delayed_job.rb', line 18 def enqueue_process(process) ::Delayed::Job.enqueue ProcessWorker.new(process.uuid), :queue => @config[:process_queue] end |
#enqueue_task(task) ⇒ Object
22 23 24 |
# File 'lib/taskinator/queues/delayed_job.rb', line 22 def enqueue_task(task) ::Delayed::Job.enqueue TaskWorker.new(task.uuid), :queue => @config[:task_queue] end |