Contents

require 'angellist_api'

module Resque
  module Plugins
    module RateLimitedQueue
      class AngellistQueue < BaseApiQueue
        WAIT_TIME = 60
        @queue = :angellist_api

        def self.perform(klass, *params)
          super
        rescue AngellistApi::Error::TooManyRequests
          pause_until(Time.now + (60 * 60))
          rate_limited_requeue(self, klass, *params)
        end
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
resque-rate_limited_queue-1.2.0	lib/resque/plugins/rate_limited_queue/apis/angellist_queue.rb
resque-rate_limited_queue-1.1.0	lib/resque/plugins/rate_limited_queue/apis/angellist_queue.rb
resque-rate_limited_queue-1.0.4	lib/resque/plugins/rate_limited_queue/apis/angellist_queue.rb
resque-rate_limited_queue-1.0.3	lib/resque/plugins/rate_limited_queue/apis/angellist_queue.rb
resque-rate_limited_queue-1.0.2	lib/resque/plugins/rate_limited_queue/apis/angellist_queue.rb
resque-rate_limited_queue-1.0.0	lib/resque/plugins/rate_limited_queue/apis/angellist_queue.rb