Module: Resque

Defined in:
lib/resque_ext/job.rb,
lib/resque_ext/resque.rb,
lib/resque_solo/unique_job.rb

Defined Under Namespace

Modules: Plugins Classes: Job

Class Method Summary collapse

Class Method Details

.enqueued?(klass, *args) ⇒ Boolean

Returns:

  • (Boolean) 


3
4
5
 
# File 'lib/resque_ext/resque.rb', line 3

def enqueued?(klass, *args)
  enqueued_in?(queue_from_class(klass), klass, *args)
end

.enqueued_in?(queue, klass, *args) ⇒ Boolean

Returns:

  • (Boolean) 


7
8
9
10
11
 
# File 'lib/resque_ext/resque.rb', line 7

def enqueued_in?(queue, klass, *args)
  item = { class: klass.to_s, args: args }
  return nil unless ResqueSolo::Queue.is_unique?(item)
  ResqueSolo::Queue.queued?(queue, item)
end

.remove_queue_with_cleanup(queue) ⇒ Object Also known as: remove_queue 



13
14
15
16
 
# File 'lib/resque_ext/resque.rb', line 13

def remove_queue_with_cleanup(queue)
  remove_queue_without_cleanup(queue)
  ResqueSolo::Queue.cleanup(queue)
end