Module: Resque
- Extended by:
- ResqueSpec::SchedulerExt
- Defined in:
- lib/resque_spec/ext.rb
Defined Under Namespace
Classes: Job
Instance Method Summary collapse
- #enqueue(klass, *args) ⇒ Object
- #enqueue_to(queue, klass, *args) ⇒ Object
- #enqueue_to_without_resque_spec ⇒ Object
- #enqueue_without_resque_spec ⇒ Object
- #peek(queue, start = 0, count = 1) ⇒ Object
- #peek_without_resque_spec ⇒ Object
- #reserve(queue_name) ⇒ Object
- #reserve_without_resque_spec ⇒ Object
- #size(queue_name) ⇒ Object
- #size_without_resque_spec ⇒ Object
Methods included from ResqueSpec::SchedulerExt
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 |