Module: EventSourcery::EventProcessing::EventStreamProcessor::ProcessHandler

Defined in:
lib/event_sourcery/event_processing/event_stream_processor.rb

Instance Method Summary collapse

Instance Method Details

#process(event) ⇒ Object

Handler that processes the given event.

Parameters:

  • event (Event) —

    the event to process

Raises:



27
28
29
30
31
32
33
34
35
36
 
# File 'lib/event_sourcery/event_processing/event_stream_processor.rb', line 27

def process(event)
  @_event = event
  handlers = (self.class.event_handlers[event.type] + [self.class.all_event_handler]).compact
  handlers.each do |handler|
    instance_exec(event, &handler)
  end
  @_event = nil
rescue
  raise EventProcessingError.new(event: event, processor: self)
end