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,
  :job_queue => :default,
}.freeze

Class Method Summary collapse

Class Method Details

.create_adapter(adapter, config = {}) ⇒ Object 



11
12
13
14
15
16
17
 
# File 'lib/taskinator/queues.rb', line 11

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

github.com/collectiveidea/delayed_job



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

github.com/resque/resque



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

github.com/mperham/sidekiq



6
7
8
 
# File 'lib/taskinator/queues/sidekiq.rb', line 6

def self.create_sidekiq_adapter(config={})
  SidekiqAdapter.new(config)
end