Module: Taskinator::Queues
- Defined in:
- lib/taskinator/queues.rb,
lib/taskinator/queues/resque.rb,
lib/taskinator/queues/sidekiq.rb,
lib/taskinator/queues/delayed_job.rb
Defined Under Namespace
Classes: DelayedJobAdapter, LoggedAdapter, ResqueAdapter, SidekiqAdapter
Constant Summary
collapse
- DefaultConfig =
{
:definition_queue => :default,
:process_queue => :default,
:task_queue => :default
}.freeze
Class Method Summary
collapse
Class Method Details
.create_adapter(adapter, config = {}) ⇒ Object
10
11
12
13
14
15
16
|
# File 'lib/taskinator/queues.rb', line 10
def self.create_adapter(adapter, config={})
begin
LoggedAdapter.new(send("create_#{adapter}_adapter", config))
rescue NoMethodError
raise "The queue adapter `#{adapter}` is not yet supported or it's runtime isn't loaded."
end
end
|
.create_delayed_job_adapter(config = {}) ⇒ Object
6
7
8
|
# File 'lib/taskinator/queues/delayed_job.rb', line 6
def self.create_delayed_job_adapter(config={})
DelayedJobAdapter.new(config)
end
|
.create_resque_adapter(config = {}) ⇒ Object
6
7
8
|
# File 'lib/taskinator/queues/resque.rb', line 6
def self.create_resque_adapter(config={})
ResqueAdapter.new(config)
end
|
.create_sidekiq_adapter(config = {}) ⇒ Object
6
7
8
|
# File 'lib/taskinator/queues/sidekiq.rb', line 6
def self.create_sidekiq_adapter(config={})
SidekiqAdapter.new(config)
end
|