class Resque::Plugins::RateLimitedQueue::UnPause

Attributes

queue[W]

Public Class Methods

class_from_string(str) click to toggle source
# File lib/resque/plugins/rate_limited_queue/rate_limited_un_pause.rb, line 29
def class_from_string(str)
  return Object.const_get(str) unless str.include?('::')
  str.split('::').reduce(Object) do |mod, class_name|
    mod.const_get(class_name)
  end
end
enqueue(timestamp, klass) click to toggle source
# File lib/resque/plugins/rate_limited_queue/rate_limited_un_pause.rb, line 14
def enqueue(timestamp, klass)
  # If Resque scheduler is installed and queue is set - use it to queue a wake up job
  return unless use?
  Resque.enqueue_at_with_queue(
    @queue,
    timestamp,
    Resque::Plugins::RateLimitedQueue::UnPause,
    klass
  )
end
perform(klass) click to toggle source
# File lib/resque/plugins/rate_limited_queue/rate_limited_un_pause.rb, line 25
def perform(klass)
  class_from_string(klass.to_s).un_pause
end
use?() click to toggle source
# File lib/resque/plugins/rate_limited_queue/rate_limited_un_pause.rb, line 10
def use?
  Resque.respond_to?(:enqueue_at_with_queue) && @queue
end