module RabbitFeed::Consumer
Attributes
event_routing[RW]
Public Instance Methods
run()
click to toggle source
# 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