Module: RabbitFeed::Consumer

Extended by:
Consumer
Included in:
Consumer
Defined in:
lib/rabbit_feed/consumer.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#event_routing ⇒ Object

Returns the value of attribute event_routing.



5
6
7
 
# File 'lib/rabbit_feed/consumer.rb', line 5

def event_routing
  @event_routing
end

Instance Method Details

#run ⇒ Object 



7
8
9
10
11
12
13
14
 
# File 'lib/rabbit_feed/consumer.rb', line 7

def run
  ConsumerConnection.instance.consume do |raw_event|
    event = Event.deserialize raw_event
    RabbitFeed.log.info { { event: :message_received, metadata: event.metadata } }
    event_routing.handle_event event
    RabbitFeed.log.info { { event: :message_processed, metadata: event.metadata } }
  end
end