Class: Resque::Job

Inherits:
Object
  • Object
show all
Defined in:
lib/resque_spec/ext.rb

Class Method Summary collapse

Class Method Details

.create(queue, klass, *args) ⇒ Object

Raises:

  • (::Resque::NoQueueError) 


10
11
12
13
14
15
16
 
# File 'lib/resque_spec/ext.rb', line 10

def self.create(queue, klass, *args)
  return create_without_resque_spec(queue, klass, *args) if ResqueSpec.disable_ext

  raise ::Resque::NoQueueError.new("Jobs must be placed onto a queue.") if !queue
  raise ::Resque::NoClassError.new("Jobs must be given a class.") if klass.to_s.empty?
  ResqueSpec.enqueue(queue, klass, *args)
end

.create_without_resque_spec ⇒ Object 



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

alias :create_without_resque_spec :create

.destroy(queue, klass, *args) ⇒ Object

Raises:

  • (::Resque::NoQueueError) 


18
19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/resque_spec/ext.rb', line 18

def self.destroy(queue, klass, *args)
  return destroy_without_resque_spec(queue, klass, *args) if ResqueSpec.disable_ext

  raise ::Resque::NoQueueError.new("Jobs must have been placed onto a queue.") if !queue
  raise ::Resque::NoClassError.new("Jobs must have been given a class.") if klass.to_s.empty?

  old_count = ResqueSpec.queue_by_name(queue).size

  ResqueSpec.dequeue(queue, klass, *args)

  old_count - ResqueSpec.queue_by_name(queue).size
end

.destroy_without_resque_spec ⇒ Object 



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

alias :destroy_without_resque_spec :destroy