module Taskinator::Queues

Constants

DefaultConfig

Public Class Methods

create_adapter(adapter, config={}) click to toggle source
# 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={}) click to toggle source

github.com/collectiveidea/delayed_job

# File lib/taskinator/queues/delayed_job.rb, line 6
def self.create_delayed_job_adapter(config={})
  DelayedJobAdapter.new(config)
end
create_resque_adapter(config={}) click to toggle source

github.com/resque/resque

# File lib/taskinator/queues/resque.rb, line 6
def self.create_resque_adapter(config={})
  ResqueAdapter.new(config)
end
create_sidekiq_adapter(config={}) click to toggle source

github.com/mperham/sidekiq

# File lib/taskinator/queues/sidekiq.rb, line 6
def self.create_sidekiq_adapter(config={})
  SidekiqAdapter.new(config)
end