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