Module: ResqueSpec

Extended by:
ResqueSpec
Included in:
ResqueSpec
Defined in:
lib/resque_spec.rb

Defined Under Namespace

Modules: Resque

Instance Method Summary collapse

Instance Method Details

#in_queue?(klass, *args) ⇒ Boolean

Returns:

  • (Boolean) 


6
7
8
 
# File 'lib/resque_spec.rb', line 6

def in_queue?(klass, *args)
  queue_for(klass).any? {|entry| entry[:klass] == klass && entry[:args] == args}
end

#queue_for(klass) ⇒ Object

Raises:

  • (::Resque::NoQueueError) 


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

def queue_for(klass)
  queue_name = klass.instance_variable_get(:@queue) || klass.respond_to?(:queue) && klass.queue
  raise ::Resque::NoQueueError.new("Jobs must be placed onto a queue.") unless queue_name
  queues[queue_name]
end

#queues ⇒ Object 



16
17
18
 
# File 'lib/resque_spec.rb', line 16

def queues
  @queues ||= Hash.new {|h,k| h[k] = []}
end

#reset! ⇒ Object 



20
21
22
 
# File 'lib/resque_spec.rb', line 20

def reset!
  queues.clear
end