Class: AutomateEm::ScheduleProxy

Inherits:
Object
  • Object
show all
Defined in:
lib/automate-em/utilities.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ ScheduleProxy

Returns a new instance of ScheduleProxy.



53
54
55
56
 
# File 'lib/automate-em/utilities.rb', line 53

def initialize
  @jobs = {}
  @index = 0
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(name, *args, &block) ⇒ Object (protected) 



71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
 
# File 'lib/automate-em/utilities.rb', line 71

def method_missing(name, *args, &block)
      EM.schedule do
        begin
          if block.present?
            job = nil
            
            if [:in, :at].include?(name)
              index = @index       # local variable for the block

              
              job = AutomateEm::scheduler.send(name, *args) do
begin
  block.call
rescue => e
  AutomateEm.print_error(System.logger, e, :message => "Error in one off scheduled event")
ensure
  EM.schedule do
    @jobs.delete(index)
  end
end
              end
            else
              job = AutomateEm::scheduler.send(name, *args) do
begin
  block.call
rescue => e
  AutomateEm.print_error(System.logger, e, :message => "Error in repeated scheduled event")
end
              end
            end
            
            if job.present?
              @jobs[@index] = job
              job = JobProxy.new(@jobs, @index, @job_lock)
              
              @index += 1
              
              return job
            end
            
            return nil
          else
            AutomateEm::scheduler.send(name, *args, &block)
          end
        rescue
        end
      end
end

Instance Method Details

#clear_jobs ⇒ Object 



58
59
60
61
62
63
64
65
66
67
 
# File 'lib/automate-em/utilities.rb', line 58

def clear_jobs
  EM.schedule do
    @jobs.each_value do |job|
      job.unschedule
    end
    
    @jobs = {}
    @index = 0
  end
end