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.



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

def initialize
	@jobs = {}
	@index = 0
	@job_lock = Mutex.new
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

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



70
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
 
# File 'lib/automate-em/utilities.rb', line 70

def method_missing(name, *args, &block)
			@job_lock.synchronize do
				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
@job_lock.synchronize 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
			end
end

Instance Method Details

#clear_jobs ⇒ Object 



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

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