class Fluent::ExecFilterOutput::JSONParser

def call(io)

def call(io)
  y = Yajl::Parser.new
  y.on_parse_complete = @on_message
  y.parse(io)
end