class Q::Methods::ThreadedInMemoryQueue::QueueBuild
Public Class Methods
call(options={}, &job)
click to toggle source
# File lib/q/methods/threaded_in_memory_queue.rb, line 25 def self.call(options={}, &job) base = options[:base] queue_name = options[:queue_name] queue_klass_name = options[:queue_klass_name] raise Q::DuplicateQueueClassError.new(base, queue_klass_name) if Q.const_defined_on?(base, queue_klass_name) queue_klass = Class.new do def self.call(*args) @job.call(*args) end def self.job=(job) @job = job end end queue_klass.job = job base.const_set(queue_klass_name, queue_klass) return true end
job=(job)
click to toggle source
# File lib/q/methods/threaded_in_memory_queue.rb, line 37 def self.job=(job) @job = job end