Method: ActiveProjection::EventClient#listen_for_events

Defined in:
lib/active_projection/event_client.rb

#listen_for_events ⇒ Object 



30
31
32
33
34
35
 
# File 'lib/active_projection/event_client.rb', line 30

def listen_for_events
  subscribe_to event_queue do |delivery_info, properties, body|
    event_received properties, body
    send_browser_notification properties.headers[:id]
  end
end