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_scheduleObject


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

def work_schedule
  Maxwell.runner[:work_schedule]
end