Class: Resque::Job
- Inherits:
-
Object
- Object
- Resque::Job
- Defined in:
- lib/resque-fanout/job_extension.rb
Class Method Summary collapse
Class Method Details
.create(queue, klass, *args) ⇒ Object
3 4 5 6 7 8 9 10 11 12 13 14 15 |
# File 'lib/resque-fanout/job_extension.rb', line 3 def self.create(queue, klass, *args) Resque.validate(klass, queue) if Resque.inline? new(:inline, {'class' => klass, 'args' => decode(encode(args))}).perform elsif queues = Resque.queues_for(queue) queues.each do |_queue| Resque.push(_queue[:queue], :class => (_queue[:class] || klass.to_s), :args => args) end else Resque.push(queue, :class => klass.to_s, :args => args) end end |