Contents

module RabbitFeed
  module Consumer
    extend self

    attr_accessor :event_routing

    def run
      ConsumerConnection.consume do |raw_event|
        event = Event.deserialize raw_event
        event_routing.handle_event event
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
rabbit_feed-2.1.5	lib/rabbit_feed/consumer.rb
rabbit_feed-2.1.2	lib/rabbit_feed/consumer.rb
rabbit_feed-2.1.1	lib/rabbit_feed/consumer.rb
rabbit_feed-2.1.0	lib/rabbit_feed/consumer.rb
rabbit_feed-2.0.0	lib/rabbit_feed/consumer.rb
rabbit_feed-1.0.2	lib/rabbit_feed/consumer.rb
rabbit_feed-1.0.1	lib/rabbit_feed/consumer.rb
rabbit_feed-1.0.0	lib/rabbit_feed/consumer.rb
rabbit_feed-0.3.1	lib/rabbit_feed/consumer.rb