class LogStash::Codecs::Base

def accept(listener)
  decode(listener.data) do |event|
    listener.process_event(event)
  end
end

def auto_flush(*)
end