Module: LazyResque::ResqueExtensions

Defined in:
lib/lazy_resque/resque_extensions.rb

Overview

Extensions to append to the main Resque module to add Resque.lazy_enqueue and Resque.process_lazy_enqueues

Instance Method Summary collapse

Instance Method Details

#lazy_enqueue(klass, *args) ⇒ Object 



10
11
12
 
# File 'lib/lazy_resque/resque_extensions.rb', line 10

def lazy_enqueue(klass, *args)
  LazyResque::Store.queue_up(LazyResque::LazyEnqueue.new(klass, *args))
end

#process_lazy_enqueues ⇒ Object 



14
15
16
17
18
19
20
 
# File 'lib/lazy_resque/resque_extensions.rb', line 14

def process_lazy_enqueues
  current_queue = LazyResque::Store.queue
  return if current_queue.empty?
  Thread.new(current_queue) do |jobs_to_be_enqueued|
    jobs_to_be_enqueued.each(&:enqueue)
  end
end