Class: Resque::Job

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

Instance Method Summary collapse

Instance Method Details

#perform ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
 
# File 'lib/hirefire/workers/resque/job.rb', line 9

def perform
  job = payload_class
  job_args = args || []
  job_was_performed = false

  before_hooks  = Plugin.before_hooks(job)
  around_hooks  = Plugin.around_hooks(job)
  after_hooks   = Plugin.after_hooks(job)
  failure_hooks = Plugin.failure_hooks(job)

  begin
    begin
      before_hooks.each do |hook|
        job.send(hook, *job_args)
      end
    rescue DontPerform
      return false
    end

    if around_hooks.empty?
      job.perform(*job_args)
      job_was_performed = true
    else
      stack = around_hooks.reverse.inject(nil) do |last_hook, hook|
        if last_hook
          lambda do
            job.send(hook, *job_args) { last_hook.call }
          end
        else
          lambda do
            job.send(hook, *job_args) do
              result = job.perform(*job_args)
              job_was_performed = true
              result
            end
          end
        end
      end
      stack.call
    end

    ##
    # HireFire Hook
    # After a job finishes processing, we invoke the #fire
    # method on the environment object which will check to see whether
    # we can fire all the hired workers
    ::Resque::Job.environment.fire

    after_hooks.each do |hook|
      job.send(hook, *job_args)
    end

    return job_was_performed

  rescue Object => e
    failure_hooks.each { |hook| job.send(hook, e, *job_args) }
    raise e
  end
end