Contents

module RosettaQueue
  
  class BaseManager
    attr_reader :consumers

    class << self
      def create
        yield self.new
      end
    end
    
    def initialize
      @consumers  = {}
    end
    
    def add(message_handler)
      key = message_handler.class.to_s.underscore.to_sym
      @consumers[key] = Consumer.new(message_handler)
    end
    
  end  
end

Version data entries

2 entries across 2 versions & 2 rubygems

Version	Path
bmabey-rosetta_queue-0.1.3	lib/rosetta_queue/consumer_managers/base.rb
cwyckoff-rosetta_queue-0.2.0	lib/rosetta_queue/consumer_managers/base.rb