class Maxwell::Agent::Worker
Public Instance Methods
perform(work)
click to toggle source
# File lib/maxwell/agent/worker.rb, line 5 def perform(work) work.perform post_run(work) ensure work_schedule.put_back(work) end
work_schedule()
click to toggle source
# File lib/maxwell/agent/worker.rb, line 13 def work_schedule Agent.runner[:work_schedule] end
Private Instance Methods
post_run(work)
click to toggle source
# File lib/maxwell/agent/worker.rb, line 19 def post_run(work) work.perform_at = nil work.last_run = Time.now Agent.runner[:middleware_runner].inoke(work) end