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