Method: ActiveProjection::EventClient#start

Defined in:
lib/active_projection/event_client.rb

#start ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/active_projection/event_client.rb', line 12

def start
  event_connection.start
  sync_projections
  listen_for_events
  request_missing_events
  event_channel.work_pool.join
rescue Interrupt
  LOGGER.info 'Catching Interrupt'
rescue Exception => e
  LOGGER.error e.message
  LOGGER.error e.backtrace.join("\n")
  raise e
end