Contents

module RabbitFeed
  module Consumer
    extend self

    attr_accessor :event_routing

    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
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
rabbit_feed-3.0.3	lib/rabbit_feed/consumer.rb
rabbit_feed-3.0.2	lib/rabbit_feed/consumer.rb
rabbit_feed-3.0.1	lib/rabbit_feed/consumer.rb
rabbit_feed-3.0.0	lib/rabbit_feed/consumer.rb