Class: Q::Methods::Sidekiq::QueueMethod

Inherits:
Object
  • Object
show all
Defined in:
lib/q/methods/sidekiq.rb

Overview

Example SinatraWorker.perform_async params

Class Method Summary collapse

Class Method Details

.call(options = {}) ⇒ Object

Raises:



110
111
112
113
114
115
116
117
118
119
120
121
 
# File 'lib/q/methods/sidekiq.rb', line 110

def self.call(options = {})
  base             = options[:base]
  queue_name       = options[:queue_name]
  queue_klass_name = options[:queue_klass_name]
  queue_klass      = base.const_get(queue_klass_name)

  raise Q::DuplicateQueueMethodError.new(base, queue_name) if base.queue.respond_to?(queue_name)

  base.queue.define_singleton_method(queue_name) do |*args|
    queue_klass.perform_async(*args)
  end
end