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