module MultiWorker
Constants
- AdapterNames
- VERSION
Attributes
default_queue[RW]
Public Class Methods
adapter(adapter_name=nil)
click to toggle source
# File lib/multi_worker.rb, line 71 def adapter(adapter_name=nil) adapter_name ||= default_adapter @adapters[adapter_name] ||= begin require "multi_worker/adapters/#{adapter_name}" klass_name = adapter_name.to_s.split('_').map(&:capitalize) * '' MultiWorker::Adapters.const_get(klass_name) end end
configure(&block)
click to toggle source
# File lib/multi_worker.rb, line 28 def configure(&block) instance_eval &block end
default_adapter(adapter_name=nil)
click to toggle source
# File lib/multi_worker.rb, line 51 def default_adapter(adapter_name=nil) return (@default_adapter = adapter_name) if (adapter_name && !adapter_name.empty?) @default_adapter ||= case when defined?(::Resque) then :resque when defined?(::Sidekiq) then :sidekiq when defined?(::Delayed::Worker) then :delayed_job when defined?(::Qu) then :qu when defined?(::QC::Queue) then :queue_classic when defined?(::Que) then :que when defined?(::Sneakers::Worker) then :sneakers when defined?(::TorqueBox::Messaging::Backgroundable) then :torquebox_backgroundable when defined?(::ThreadedInMemoryQueue) then :threaded_in_memory_queue when defined?(::SuckerPunch::Job) then :sucker_punch when defined?(::Backburner) then :backburner when defined?(::Toro) then :toro else :inline end end
default_options(opts={})
click to toggle source
# File lib/multi_worker.rb, line 32 def default_options(opts={}) @default_options ||= { adapter: default_adapter, queue: default_queue, status: false, retry: false, lock: false, unique: false } if opts && !opts.empty? @default_options.merge!(opts) end @default_options end
enqueue(worker_klass, *args)
click to toggle source
# File lib/multi_worker.rb, line 24 def enqueue(worker_klass, *args) worker_klass.perform_async(*args) end