Method: FluQ::Worker#process

Defined in:
lib/fluq/worker.rb

#process(events) ⇒ Object

Parameters:



20
21
22
23
24
25
26
 
# File 'lib/fluq/worker.rb', line 20

def process(events)
  events.freeze # Freeze events, don't allow individual handlers to modify them
  handlers.each do |handler|
    on_events(handler, Time.now, events)
  end
  true
end