class Fluent::ExecFilterOutput::Parser

def initialize(on_message)

def initialize(on_message)
  @on_message = on_message
end