class Alephant::Publisher::Request::BaseProcessor

Public Instance Methods

consume(data) click to toggle source
# File lib/alephant/publisher/request/processor/base.rb, line 5
def consume(data)
  raise NotImplementedError.new("You must implement the #consume(data) method")
end