Class: Maxwell::Agent::Worker

Inherits:
Object
  • Object
show all
Includes:
Celluloid
Defined in:
lib/maxwell/agent/worker.rb

Instance Method Summary collapse

Instance Method Details

#perform(work) ⇒ Object 


6
7
8
9
10
11
12
 
# File 'lib/maxwell/agent/worker.rb', line 6

def perform(work)
  work.perform

  post_run(work)
ensure
  work_schedule.put_back(work)
end

#work_schedule ⇒ Object 


14
15
16
 
# File 'lib/maxwell/agent/worker.rb', line 14

def work_schedule
  Maxwell.runner[:work_schedule]
end