Class: Alephant::Publisher::BaseProcessor

Inherits:

Object

Object
Alephant::Publisher::BaseProcessor

Defined in:: lib/alephant/publisher/processor/base.rb

Direct Known Subclasses

Instance Method Summary collapse

#consume(msg) ⇒ Object

Instance Method Details

#consume(msg) ⇒ `Object`

Raises:

(NotImplementedError)



5
6
7

# File 'lib/alephant/publisher/processor/base.rb', line 5

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