Class: HireFire::Initializer

Inherits:
Object
  • Object
show all
Defined in:
lib/hirefire/initializer.rb

Class Method Summary collapse

Class Method Details

.initialize! ⇒ nil

Note:

Either the Delayed Job, or the Resque worker library must be loaded BEFORE HireFire initializes, otherwise it’ll be unable to detect the proper library and it will not work.

Loads the HireFire extension in to the loaded worker library and extends that library by injecting HireFire hooks in the proper locations.

Currently it supports:

- Delayed Job
  - ActiveRecord ORM
  - Mongoid ODM
- Resque
  - Redis

Returns:

  • (nil) 


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
68
69
70
 
# File 'lib/hirefire/initializer.rb', line 23

def self.initialize!

  ##
  # Initialize Delayed::Job extensions if Delayed::Job is found
  if defined?(::Delayed::Job)
    ##
    # If DelayedJob is using ActiveRecord, then include
    # HireFire::Environment in to the ActiveRecord Delayed Job Backend
    if defined?(::Delayed::Backend::ActiveRecord::Job)
      ::Delayed::Backend::ActiveRecord::Job.
      send(:include, HireFire::Environment).
      send(:include, HireFire::Backend)
    end

    ##
    # If DelayedJob is using Mongoid, then include
    # HireFire::Environment in to the Mongoid Delayed Job Backend
    if defined?(::Delayed::Backend::Mongoid::Job)
      ::Delayed::Backend::Mongoid::Job.
      send(:include, HireFire::Environment).
      send(:include, HireFire::Backend)
    end

    ##
    # Load Delayed Job extensions, this will patch Delayed::Worker
    # to implement the necessary hooks to invoke HireFire from
    require File.join(HireFire::WORKERS_PATH, 'delayed_job')
  end

  ##
  # Initialize Resque extensions if Resque is found
  if defined?(::Resque)

    ##
    # Include the HireFire::Environment which will add an instance
    # of HireFire::Environment::(Heroku|Local|Noop) to the Resque::Job.environment class method
    #
    # Extend the Resque::Job class with the Resque::Job.jobs class method
    ::Resque::Job.
    send(:include, HireFire::Environment).
    send(:extend, HireFire::Backend::Resque::Redis)

    ##
    # Load Resque extensions, this will patch Resque, Resque::Job and Resque::Worker
    # to implement the necessary hooks to invoke HireFire from
    require File.join(HireFire::WORKERS_PATH, 'resque')
  end
end