Module: Resque

Extended by:
ResqueSpec::SchedulerExt
Defined in:
lib/resque_spec/ext.rb

Defined Under Namespace

Classes: Job

Instance Method Summary collapse

Methods included from ResqueSpec::SchedulerExt

extended

Instance Method Details

#enqueue(klass, *args) ⇒ Object 



38
39
40
41
42
 
# 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

#enqueue_to(queue, klass, *args) ⇒ Object 



44
45
46
47
48
49
50
51
52
53
54
55
56
57
 
# 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

#enqueue_to_without_resque_spec ⇒ Object 



33
 
# File 'lib/resque_spec/ext.rb', line 33

alias :enqueue_to_without_resque_spec :enqueue_to

#enqueue_without_resque_spec ⇒ Object 



32
 
# File 'lib/resque_spec/ext.rb', line 32

alias :enqueue_without_resque_spec :enqueue

#peek(queue, start = 0, count = 1) ⇒ Object 



59
60
61
62
63
64
 
# 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

#peek_without_resque_spec ⇒ Object 



35
 
# File 'lib/resque_spec/ext.rb', line 35

alias :peek_without_resque_spec :peek

#reserve(queue_name) ⇒ Object 



66
67
68
69
70
 
# 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

#reserve_without_resque_spec ⇒ Object 



34
 
# File 'lib/resque_spec/ext.rb', line 34

alias :reserve_without_resque_spec :reserve

#size(queue_name) ⇒ Object 



72
73
74
75
76
 
# 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

#size_without_resque_spec ⇒ Object 



36
 
# File 'lib/resque_spec/ext.rb', line 36

alias :size_without_resque_spec :size