Class: Resque::Job

Inherits:
Object
  • Object
show all
Defined in:
lib/resque/plugins/job.rb

Class Method Summary collapse

Class Method Details

.origin_reserve ⇒ Object 



4
 
# File 'lib/resque/plugins/job.rb', line 4

alias_method :origin_reserve, :reserve

.reserve(queue) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/resque/plugins/job.rb', line 6

def reserve(queue)
  if queue =~ /^#{Plugins::Restriction::RESTRICTION_QUEUE_PREFIX}/
    # If processing the restriction queue, when poping and pushing to end,
    # we can't tell when we reach the original one, so just walk the length
    # of the queue or up to max_queue_peek so we don't run infinitely long
    [Resque.size(queue), Restriction.config.max_queue_peek(queue)].compact.min.times do
      # For the job at the head of the queue, repush to restricition queue
      # if still restricted, otherwise we have a runnable job, so create it
      # and return
      payload = Resque.pop(queue)
      if payload
        if !Object.const_get(payload['class']).repush(*payload['args'])
          return new(queue, payload)
        end
      end
    end
    nil
  else
    # drop through to original Job::Reserve if not restriction queue
    origin_reserve(queue)
  end
end