Contents

module Alephant
  module Publisher
    class BaseProcessor

      def consume(msg)
        raise NotImplementedError.new("You must implement the #consume(msg) method")
      end

    end
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
alephant-publisher-0.6.10	lib/alephant/publisher/processor/base.rb
alephant-publisher-0.6.9	lib/alephant/publisher/processor/base.rb
alephant-publisher-0.6.8	lib/alephant/publisher/processor/base.rb
alephant-publisher-0.6.7	lib/alephant/publisher/processor/base.rb
alephant-publisher-0.6.6	lib/alephant/publisher/processor/base.rb
alephant-publisher-0.6.5	lib/alephant/publisher/processor/base.rb
alephant-publisher-0.6.4	lib/alephant/publisher/processor/base.rb
alephant-publisher-0.6.3	lib/alephant/publisher/processor/base.rb
alephant-publisher-0.6.2	lib/alephant/publisher/processor/base.rb
alephant-publisher-0.6.1	lib/alephant/publisher/processor/base.rb
alephant-publisher-0.5.1	lib/alephant/publisher/processor/base.rb
alephant-publisher-0.5.0	lib/alephant/publisher/processor/base.rb