Method: ActiveProjection::EventClient#event_received

Defined in:
lib/active_projection/event_client.rb

#event_received(properties, body) ⇒ Object 



65
66
67
68
69
 
# File 'lib/active_projection/event_client.rb', line 65

def event_received(properties, body)
  RELOADER.execute_if_updated
  LOGGER.debug "Received #{properties.type} with #{body}"
  ProjectionTypeRegistry.process properties.headers.deep_symbolize_keys!, build_event(properties.type, JSON.parse(body))
end