module Resque

Public Instance Methods

enqueue(klass, *args) click to toggle source
# File lib/tresque/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/tresque/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
enqueue_to_without_resque_spec(queue, klass, *args)
Alias for: enqueue_to
enqueue_without_resque_spec(klass, *args)
Alias for: enqueue
peek(queue, start = 0, count = 1) click to toggle source
# File lib/tresque/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
peek_without_resque_spec(queue, start = 0, count = 1)
Alias for: peek
reserve(queue_name) click to toggle source
# File lib/tresque/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
reserve_without_resque_spec(queue_name)
Alias for: reserve
size(queue_name) click to toggle source
# File lib/tresque/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
size_without_resque_spec(queue_name)
Alias for: size

Private Instance Methods

run_after_enqueue(klass, *args) click to toggle source
# File lib/tresque/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/tresque/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