resque_helper.rb

module ResqueHelper
  def already_queued?(queue = @queue, &block)
    queue_data = Resque.peek(queue, 0, -1)
    return false unless queue_data
    
    case queue_data
    when Array
      queue_data.any? do |job|
        block.call(job["args"])
      end
    when Hash
      args = queue_data["args"]
      return block.call(args)
    else
      return false
    end
  end
  module_function :already_queued?
end