Class: Resque::Plugins::RateLimited::TwitterQueue

Inherits:
BaseApiQueue
  • Object
show all
Defined in:
lib/resque/plugins/rate_limited/apis/twitter_queue.rb

Constant Summary

Constants included from Resque::Plugins::RateLimited

MUTEX, RESQUE_PREFIX

Class Method Summary collapse

Methods inherited from BaseApiQueue

enqueue

Methods included from Resque::Plugins::RateLimited

#around_perform_with_check_and_requeue, #find_class, #pause, #pause_until, #paused?, #paused_queue_name, #prefixed, #rate_limited_enqueue, #rate_limited_requeue, #un_pause, #with_lock

Class Method Details

.perform(klass, *params) ⇒ Object



9
10
11
12
13
14
15
# File 'lib/resque/plugins/rate_limited/apis/twitter_queue.rb', line 9

def self.perform(klass, *params)
  super
rescue Twitter::Error::TooManyRequests,
       Twitter::Error::EnhanceYourCalm => e
  pause_until(Time.now + e.rate_limit.reset_in)
  rate_limited_requeue(self, klass, *params)
end