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, ResqueAdapter, SidekiqAdapter

Class Method Summary collapse

Class Method Details

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



4
5
6
7
8
9
10
 
# File 'lib/taskinator/queues.rb', line 4

def self.create_adapter(adapter, config={})
  begin
    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