module Resque
Public Instance Methods
enqueue(klass, *args)
click to toggle source
# File lib/resque_spec/ext.rb, line 38 def enqueue(klass, *args) return enqueue_without_resque_spec(klass, *args) if ResqueSpec.disable_ext enqueue_to(queue_from_class(klass), klass, *args) end
Also aliased as: enqueue_without_resque_spec
enqueue_to(queue, klass, *args)
click to toggle source
# File lib/resque_spec/ext.rb, line 44 def enqueue_to(queue, klass, *args) return enqueue_to_without_resque_spec(queue, klass, *args) if ResqueSpec.disable_ext if ResqueSpec.inline return if run_before_enqueue(klass, *args) run_after_enqueue(klass, *args) Job.create(queue, klass, *args) else return if run_before_enqueue(klass, *args) Job.create(queue, klass, *args) run_after_enqueue(klass, *args) true end end
Also aliased as: enqueue_to_without_resque_spec
peek(queue, start = 0, count = 1)
click to toggle source
# File lib/resque_spec/ext.rb, line 59 def peek(queue, start = 0, count = 1) return peek_without_resque_spec(queue, start, count) if ResqueSpec.disable_ext ResqueSpec.peek(queue, start, count).map do |job| job.inject({}) { |a, (k, v)| a[k.to_s] = v; a } end end
Also aliased as: peek_without_resque_spec
reserve(queue_name)
click to toggle source
# File lib/resque_spec/ext.rb, line 66 def reserve(queue_name) return reserve_without_resque_spec(queue_name) if ResqueSpec.disable_ext ResqueSpec.pop(queue_name) end
Also aliased as: reserve_without_resque_spec
size(queue_name)
click to toggle source
# File lib/resque_spec/ext.rb, line 72 def size(queue_name) return size_without_resque_spec(queue_name) if ResqueSpec.disable_ext ResqueSpec.queue_by_name(queue_name).count end
Also aliased as: size_without_resque_spec
Private Instance Methods
run_after_enqueue(klass, *args)
click to toggle source
# File lib/resque_spec/ext.rb, line 80 def run_after_enqueue(klass, *args) Plugin.after_enqueue_hooks(klass).each do |hook| klass.send(hook, *args) end end
run_before_enqueue(klass, *args)
click to toggle source
# File lib/resque_spec/ext.rb, line 86 def run_before_enqueue(klass, *args) before_hooks = Plugin.before_enqueue_hooks(klass).collect do |hook| klass.send(hook, *args) end before_hooks.any? { |result| result == false } end