Contents

module Resque
  class << self
    # Override
    # https://github.com/resque/resque/blob/master/lib/resque.rb
    def enqueue_to(queue, klass, *args)
      # Perform before_enqueue hooks. Don't perform enqueue if any hook returns false
      before_hooks = Plugin.before_enqueue_hooks(klass).collect do |hook|
        klass.send(hook, *args)
      end
      return nil if before_hooks.any? { |result| result == false }

      result = Job.create(queue, klass, *args)
      return nil if result == 'EXISTED'

      Plugin.after_enqueue_hooks(klass).each do |hook|
        klass.send(hook, *args)
      end

      true
    end

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

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

      Resque::UniqueInQueue::Queue.queued?(queue, item)
    end

    def remove_queue_with_unique_in_queue_cleanup(queue)
      remove_queue_without_unique_in_queue_cleanup(queue)
      Resque::UniqueInQueue::Queue.cleanup(queue)
    end

    alias remove_queue_without_unique_in_queue_cleanup remove_queue
    alias remove_queue remove_queue_with_unique_in_queue_cleanup
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
resque-unique_in_queue-2.0.1	lib/resque/unique_in_queue/resque_ext/resque.rb
resque-unique_in_queue-2.0.0	lib/resque/unique_in_queue/resque_ext/resque.rb
resque-unique_in_queue-1.0.3	lib/resque/unique_in_queue/resque_ext/resque.rb
resque-unique_in_queue-1.0.2	lib/resque/unique_in_queue/resque_ext/resque.rb
resque-unique_in_queue-1.0.1	lib/resque/unique_in_queue/resque_ext/resque.rb
resque-unique_in_queue-1.0.0	lib/resque/unique_in_queue/resque_ext/resque.rb