Contents

module Resque
  class Job
    class <<self
      alias_method :origin_reserve, :reserve
      
      def reserve(queue)
        if queue == 'restriction' && payload = Resque.pop(queue)
          constantize(payload['class']).repush(*payload['args'])
          return
        end
        origin_reserve(queue)
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
resque-restriction-0.2.1	lib/resque-restriction/job.rb
resque-restriction-0.2.0	lib/resque-restriction/job.rb