Contents

module Resque

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

  def self.enqueued_in?(queue, klass, *args)
    item = { :class => klass.to_s, :args => args }
    return nil unless Resque::Plugins::Loner::Helpers.item_is_a_unique_job?(item)
    Resque::Plugins::Loner::Helpers.loner_queued?(queue, item)
  end

  def self.remove_queue_with_loner_cleanup(queue)
    self.remove_queue_without_loner_cleanup(queue)
    Resque::Plugins::Loner::Helpers.cleanup_loners(queue)
  end


  class << self

    alias_method :remove_queue_without_loner_cleanup, :remove_queue
    alias_method :remove_queue, :remove_queue_with_loner_cleanup

  end

end

Version data entries

5 entries across 5 versions & 3 rubygems

Version	Path
nogara-resque-loner-1.2.1	lib/resque-ext/resque.rb
resque-loner-1.2.1	lib/resque-ext/resque.rb
resque-loner-1.2.0	lib/resque-ext/resque.rb
ryansch-resque-loner-1.0.1.2	lib/resque-ext/resque.rb
ryansch-resque-loner-1.0.1.1	lib/resque-ext/resque.rb